Package org.apache.camel.component.zookeeper.cluster

Class ZooKeeperClusterService

java.lang.Object
org.apache.camel.support.service.BaseService
org.apache.camel.support.service.ServiceSupport
org.apache.camel.support.cluster.AbstractCamelClusterService<org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterView>
org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterService
All Implemented Interfaces:
AutoCloseable, org.apache.camel.CamelContextAware, org.apache.camel.cluster.CamelClusterService, org.apache.camel.Ordered, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasCamelContext, org.apache.camel.spi.HasId, org.apache.camel.spi.IdAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class ZooKeeperClusterService extends org.apache.camel.support.cluster.AbstractCamelClusterService<org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterView>

  • Constructor Details

    • ZooKeeperClusterService

      public ZooKeeperClusterService()

    • ZooKeeperClusterService

      public ZooKeeperClusterService(ZooKeeperCuratorConfiguration configuration)

  • Method Details

    • getConfiguration

      public ZooKeeperCuratorConfiguration getConfiguration()

    • setConfiguration

      public void setConfiguration(ZooKeeperCuratorConfiguration configuration)

    • getCuratorFramework

      public org.apache.curator.framework.CuratorFramework getCuratorFramework()

    • setCuratorFramework

      public void setCuratorFramework(org.apache.curator.framework.CuratorFramework curatorFramework)

    • getNodes

      public List<String> getNodes()

    • setNodes

      public void setNodes(String nodes)

    • setNodes

      public void setNodes(List<String> nodes)

    • getNamespace

      public String getNamespace()

    • setNamespace

      public void setNamespace(String namespace)

    • getReconnectBaseSleepTime

      public long getReconnectBaseSleepTime()

    • setReconnectBaseSleepTime

      public void setReconnectBaseSleepTime(long reconnectBaseSleepTime)

    • setReconnectBaseSleepTime

      public void setReconnectBaseSleepTime(long reconnectBaseSleepTime, TimeUnit reconnectBaseSleepTimeUnit)

    • getReconnectBaseSleepTimeUnit

      public TimeUnit getReconnectBaseSleepTimeUnit()

    • setReconnectBaseSleepTimeUnit

      public void setReconnectBaseSleepTimeUnit(TimeUnit reconnectBaseSleepTimeUnit)

    • getReconnectMaxRetries

      public int getReconnectMaxRetries()

    • setReconnectMaxRetries

      public void setReconnectMaxRetries(int reconnectMaxRetries)

    • getSessionTimeout

      public long getSessionTimeout()

    • setSessionTimeout

      public void setSessionTimeout(long sessionTimeout)

    • setSessionTimeout

      public void setSessionTimeout(long sessionTimeout, TimeUnit sessionTimeoutUnit)

    • getSessionTimeoutUnit

      public TimeUnit getSessionTimeoutUnit()

    • setSessionTimeoutUnit

      public void setSessionTimeoutUnit(TimeUnit sessionTimeoutUnit)

    • getConnectionTimeout

      public long getConnectionTimeout()

    • setConnectionTimeout

      public void setConnectionTimeout(long connectionTimeout)

    • setConnectionTimeout

      public void setConnectionTimeout(long connectionTimeout, TimeUnit connectionTimeotUnit)

    • getConnectionTimeoutUnit

      public TimeUnit getConnectionTimeoutUnit()

    • setConnectionTimeoutUnit

      public void setConnectionTimeoutUnit(TimeUnit connectionTimeotUnit)

    • getAuthInfoList

      public List<org.apache.curator.framework.AuthInfo> getAuthInfoList()

    • setAuthInfoList

      public void setAuthInfoList(List<org.apache.curator.framework.AuthInfo> authInfoList)

    • getMaxCloseWait

      public long getMaxCloseWait()

    • setMaxCloseWait

      public void setMaxCloseWait(long maxCloseWait)

    • getMaxCloseWaitUnit

      public TimeUnit getMaxCloseWaitUnit()

    • setMaxCloseWaitUnit

      public void setMaxCloseWaitUnit(TimeUnit maxCloseWaitUnit)

    • getRetryPolicy

      public org.apache.curator.RetryPolicy getRetryPolicy()

    • setRetryPolicy

      public void setRetryPolicy(org.apache.curator.RetryPolicy retryPolicy)

    • getBasePath

      public String getBasePath()

    • setBasePath

      public void setBasePath(String basePath)

    • createView

      protected org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterView createView(String namespace) throws Exception
      Specified by:
      createView in class org.apache.camel.support.cluster.AbstractCamelClusterService<org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterView>
      Throws:
      Exception

    • doStart

      protected void doStart() throws Exception
      Overrides:
      doStart in class org.apache.camel.support.cluster.AbstractCamelClusterService<org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterView>
      Throws:
      Exception

    • doStop

      protected void doStop() throws Exception
      Overrides:
      doStop in class org.apache.camel.support.cluster.AbstractCamelClusterService<org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterView>
      Throws:
      Exception