org.apache.camel.component.zookeeper.cloud

Class ZooKeeperServiceRegistry

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.cloud.AbstractServiceRegistry

org.apache.camel.component.zookeeper.cloud.ZooKeeperServiceRegistry

All Implemented Interfaces:

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.HasId, org.apache.camel.spi.IdAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class ZooKeeperServiceRegistry
extends org.apache.camel.impl.cloud.AbstractServiceRegistry

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ZooKeeperServiceRegistry.MetaData

Nested classes/interfaces inherited from interface org.apache.camel.cloud.ServiceRegistry

org.apache.camel.cloud.ServiceRegistry.Selector

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Fields inherited from interface org.apache.camel.Ordered

HIGHEST, LOWEST

Constructor Summary

Constructors

Constructor and Description
ZooKeeperServiceRegistry()
ZooKeeperServiceRegistry(ZooKeeperServiceRegistryConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
void	deregister(org.apache.camel.cloud.ServiceDefinition definition)
protected void	doStart()
protected void	doStop()
List<org.apache.curator.framework.AuthInfo>	getAuthInfoList()
String	getBasePath()
ZooKeeperServiceRegistryConfiguration	getConfiguration()
long	getConnectionTimeout()
TimeUnit	getConnectionTimeoutUnit()
org.apache.curator.framework.CuratorFramework	getCuratorFramework()
long	getMaxCloseWait()
TimeUnit	getMaxCloseWaitUnit()
String	getNamespace()
List<String>	getNodes()
long	getReconnectBaseSleepTime()
TimeUnit	getReconnectBaseSleepTimeUnit()
int	getReconnectMaxRetries()
long	getReconnectMaxSleepTime()
TimeUnit	getReconnectMaxSleepTimeUnit()
org.apache.curator.RetryPolicy	getRetryPolicy()
String	getServiceHost()
long	getSessionTimeout()
TimeUnit	getSessionTimeoutUnit()
boolean	isDeregisterServicesOnStop()
boolean	isOverrideServiceHost()
void	register(org.apache.camel.cloud.ServiceDefinition definition)
void	setAuthInfoList(List<org.apache.curator.framework.AuthInfo> authInfoList)
void	setBasePath(String basePath)
void	setConfiguration(ZooKeeperServiceRegistryConfiguration configuration)
void	setConnectionTimeout(long connectionTimeout)
void	setConnectionTimeout(long connectionTimeout, TimeUnit connectionTimeotUnit)
void	setConnectionTimeoutUnit(TimeUnit connectionTimeoutUnit)
void	setCuratorFramework(org.apache.curator.framework.CuratorFramework curatorFramework)
void	setDeregisterServicesOnStop(boolean deregisterServicesOnStop)
void	setMaxCloseWait(long maxCloseWait)
void	setMaxCloseWaitUnit(TimeUnit maxCloseWaitUnit)
void	setNamespace(String namespace)
void	setNodes(List<String> nodes)
void	setNodes(String nodes)
void	setOverrideServiceHost(boolean overrideServiceHost)
void	setReconnectBaseSleepTime(long reconnectBaseSleepTime)
void	setReconnectBaseSleepTime(long reconnectBaseSleepTime, TimeUnit reconnectBaseSleepTimeUnit)
void	setReconnectBaseSleepTimeUnit(TimeUnit reconnectBaseSleepTimeUnit)
void	setReconnectMaxRetries(int reconnectMaxRetries)
void	setReconnectMaxSleepTime(long reconnectMaxSleepTime)
void	setReconnectMaxSleepTime(long reconnectMaxSleepTime, TimeUnit reconnectBaseSleepTimeUnit)
void	setReconnectMaxSleepTimeUnit(TimeUnit reconnectMaxSleepTimeUnit)
void	setRetryPolicy(org.apache.curator.RetryPolicy retryPolicy)
void	setServiceHost(String serviceHost)
void	setSessionTimeout(long sessionTimeout)
void	setSessionTimeout(long sessionTimeout, TimeUnit sessionTimeoutUnit)
void	setSessionTimeoutUnit(TimeUnit sessionTimeoutUnit)

Methods inherited from class org.apache.camel.impl.cloud.AbstractServiceRegistry

getAttributes, getCamelContext, getId, getOrder, setAttribute, setAttributes, setCamelContext, setId, setOrder

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

ZooKeeperServiceRegistry

public ZooKeeperServiceRegistry()

ZooKeeperServiceRegistry

public ZooKeeperServiceRegistry(ZooKeeperServiceRegistryConfiguration configuration)

Method Detail

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

Specified by:

doStart in class org.apache.camel.support.ServiceSupport

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Specified by:

doStop in class org.apache.camel.support.ServiceSupport

Throws:

Exception

register

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

deregister

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