public class ZooKeeperServiceDiscoveryFactory extends Object implements org.apache.camel.cloud.ServiceDiscoveryFactory
Constructor and Description |
---|
ZooKeeperServiceDiscoveryFactory() |
ZooKeeperServiceDiscoveryFactory(ZooKeeperCuratorConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
ZooKeeperCuratorConfiguration |
copy() |
List<org.apache.curator.framework.AuthInfo> |
getAuthInfoList() |
String |
getBasePath() |
ZooKeeperCuratorConfiguration |
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() |
long |
getSessionTimeout() |
TimeUnit |
getSessionTimeoutUnit() |
org.apache.camel.cloud.ServiceDiscovery |
newInstance(org.apache.camel.CamelContext context) |
void |
setAuthInfoList(List<org.apache.curator.framework.AuthInfo> authInfoList) |
void |
setBasePath(String basePath) |
void |
setConfiguration(ZooKeeperCuratorConfiguration configuration) |
void |
setConnectionTimeout(long connectionTimeout) |
void |
setConnectionTimeout(long connectionTimeout,
TimeUnit connectionTimeotUnit) |
void |
setConnectionTimeoutUnit(TimeUnit connectionTimeoutUnit) |
void |
setCuratorFramework(org.apache.curator.framework.CuratorFramework curatorFramework) |
void |
setMaxCloseWait(long maxCloseWait) |
void |
setMaxCloseWaitUnit(TimeUnit maxCloseWaitUnit) |
void |
setNamespace(String namespace) |
void |
setNodes(List<String> nodes) |
void |
setNodes(String nodes) |
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 |
setSessionTimeout(long sessionTimeout) |
void |
setSessionTimeout(long sessionTimeout,
TimeUnit sessionTimeoutUnit) |
void |
setSessionTimeoutUnit(TimeUnit sessionTimeoutUnit) |
public ZooKeeperServiceDiscoveryFactory()
public ZooKeeperServiceDiscoveryFactory(ZooKeeperCuratorConfiguration configuration)
public ZooKeeperCuratorConfiguration getConfiguration()
public void setConfiguration(ZooKeeperCuratorConfiguration 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 ZooKeeperCuratorConfiguration copy()
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)
Apache Camel