Package org.apache.camel.component.zookeeper.cloud

Class ZooKeeperServiceRegistry

java.lang.Object
org.apache.camel.support.service.BaseService
org.apache.camel.support.service.ServiceSupport
org.apache.camel.impl.cloud.AbstractServiceRegistry
org.apache.camel.component.zookeeper.cloud.ZooKeeperServiceRegistry
All Implemented Interfaces:
AutoCloseable, org.apache.camel.CamelContextAware, org.apache.camel.cloud.ServiceRegistry, 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 ZooKeeperServiceRegistry extends org.apache.camel.impl.cloud.AbstractServiceRegistry

  • Constructor Details

  • Method Details

    • getConfiguration

      public ZooKeeperServiceRegistryConfiguration getConfiguration()

    • setConfiguration

      public void setConfiguration(ZooKeeperServiceRegistryConfiguration 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)

    • getReconnectMaxSleepTime

      public long getReconnectMaxSleepTime()

    • setReconnectMaxSleepTime

      public void setReconnectMaxSleepTime(long reconnectMaxSleepTime)

    • setReconnectMaxSleepTime

      public void setReconnectMaxSleepTime(long reconnectMaxSleepTime, TimeUnit reconnectBaseSleepTimeUnit)

    • getReconnectMaxSleepTimeUnit

      public TimeUnit getReconnectMaxSleepTimeUnit()

    • setReconnectMaxSleepTimeUnit

      public void setReconnectMaxSleepTimeUnit(TimeUnit reconnectMaxSleepTimeUnit)

    • 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 connectionTimeoutUnit)

    • 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)

    • isDeregisterServicesOnStop

      public boolean isDeregisterServicesOnStop()

    • setDeregisterServicesOnStop

      public void setDeregisterServicesOnStop(boolean deregisterServicesOnStop)

    • isOverrideServiceHost

      public boolean isOverrideServiceHost()

    • setOverrideServiceHost

      public void setOverrideServiceHost(boolean overrideServiceHost)

    • getServiceHost

      public String getServiceHost()

    • setServiceHost

      public void setServiceHost(String serviceHost)

    • doStart

      protected void doStart() throws Exception
      Overrides:
      doStart in class org.apache.camel.support.service.BaseService
      Throws:
      Exception

    • doStop

      protected void doStop() throws Exception
      Overrides:
      doStop in class org.apache.camel.support.service.BaseService
      Throws:
      Exception

    • register

      public void register(org.apache.camel.cloud.ServiceDefinition definition)

    • deregister

      public void deregister(org.apache.camel.cloud.ServiceDefinition definition)