public class ZooKeeperServiceRegistry
extends org.apache.camel.impl.cloud.AbstractServiceRegistry
Modifier and Type | Class and Description |
---|---|
static class |
ZooKeeperServiceRegistry.MetaData |
Constructor and Description |
---|
ZooKeeperServiceRegistry() |
ZooKeeperServiceRegistry(ZooKeeperServiceRegistryConfiguration configuration) |
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) |
getAttributes, getCamelContext, getId, getOrder, setAttribute, setAttributes, setCamelContext, setId, setOrder
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public ZooKeeperServiceRegistry()
public ZooKeeperServiceRegistry(ZooKeeperServiceRegistryConfiguration configuration)
public ZooKeeperServiceRegistryConfiguration getConfiguration()
public void setConfiguration(ZooKeeperServiceRegistryConfiguration configuration)
public org.apache.curator.framework.CuratorFramework getCuratorFramework()
public void setCuratorFramework(org.apache.curator.framework.CuratorFramework curatorFramework)
public void setNodes(String nodes)
public String getNamespace()
public void setNamespace(String namespace)
public long getReconnectBaseSleepTime()
public void setReconnectBaseSleepTime(long reconnectBaseSleepTime)
public void setReconnectBaseSleepTime(long reconnectBaseSleepTime, TimeUnit reconnectBaseSleepTimeUnit)
public TimeUnit getReconnectBaseSleepTimeUnit()
public void setReconnectBaseSleepTimeUnit(TimeUnit reconnectBaseSleepTimeUnit)
public long getReconnectMaxSleepTime()
public void setReconnectMaxSleepTime(long reconnectMaxSleepTime)
public void setReconnectMaxSleepTime(long reconnectMaxSleepTime, TimeUnit reconnectBaseSleepTimeUnit)
public TimeUnit getReconnectMaxSleepTimeUnit()
public void setReconnectMaxSleepTimeUnit(TimeUnit reconnectMaxSleepTimeUnit)
public int getReconnectMaxRetries()
public void setReconnectMaxRetries(int reconnectMaxRetries)
public long getSessionTimeout()
public void setSessionTimeout(long sessionTimeout)
public void setSessionTimeout(long sessionTimeout, TimeUnit sessionTimeoutUnit)
public TimeUnit getSessionTimeoutUnit()
public void setSessionTimeoutUnit(TimeUnit sessionTimeoutUnit)
public long getConnectionTimeout()
public void setConnectionTimeout(long connectionTimeout)
public void setConnectionTimeout(long connectionTimeout, TimeUnit connectionTimeotUnit)
public TimeUnit getConnectionTimeoutUnit()
public void setConnectionTimeoutUnit(TimeUnit connectionTimeoutUnit)
public List<org.apache.curator.framework.AuthInfo> getAuthInfoList()
public void setAuthInfoList(List<org.apache.curator.framework.AuthInfo> authInfoList)
public long getMaxCloseWait()
public void setMaxCloseWait(long maxCloseWait)
public TimeUnit getMaxCloseWaitUnit()
public void setMaxCloseWaitUnit(TimeUnit maxCloseWaitUnit)
public org.apache.curator.RetryPolicy getRetryPolicy()
public void setRetryPolicy(org.apache.curator.RetryPolicy retryPolicy)
public String getBasePath()
public void setBasePath(String basePath)
public boolean isDeregisterServicesOnStop()
public void setDeregisterServicesOnStop(boolean deregisterServicesOnStop)
public boolean isOverrideServiceHost()
public void setOverrideServiceHost(boolean overrideServiceHost)
public String getServiceHost()
public void setServiceHost(String serviceHost)
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.support.ServiceSupport
Exception
public void register(org.apache.camel.cloud.ServiceDefinition definition)
public void deregister(org.apache.camel.cloud.ServiceDefinition definition)
Apache Camel