public abstract class ZookeeperComponentSupport
extends org.apache.camel.impl.DefaultComponent
Constructor and Description |
---|
ZookeeperComponentSupport() |
Modifier and Type | Method and Description |
---|---|
Group<CamelNodeState> |
createGroup(String path) |
protected void |
doStart() |
protected void |
doStop() |
org.apache.curator.framework.CuratorFramework |
getCurator() |
int |
getMaximumConnectionTimeout() |
String |
getZooKeeperPassword() |
String |
getZooKeeperUrl() |
void |
setCurator(org.apache.curator.framework.CuratorFramework curator)
To use a custom configured CuratorFramework as connection to zookeeper ensemble.
|
void |
setMaximumConnectionTimeout(int maximumConnectionTimeout)
Timeout in millis to use when connecting to the zookeeper ensemble
|
void |
setZooKeeperPassword(String zooKeeperPassword)
The password to use when connecting to the zookeeper ensemble
|
void |
setZooKeeperUrl(String zooKeeperUrl)
The url for the zookeeper ensemble
|
afterConfiguration, createComponentConfiguration, createConfiguration, createEndpoint, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isResolvePropertyPlaceholders, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, setResolvePropertyPlaceholders, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
public Group<CamelNodeState> createGroup(String path)
public org.apache.curator.framework.CuratorFramework getCurator()
public void setCurator(org.apache.curator.framework.CuratorFramework curator)
public int getMaximumConnectionTimeout()
public void setMaximumConnectionTimeout(int maximumConnectionTimeout)
public String getZooKeeperUrl()
public void setZooKeeperUrl(String zooKeeperUrl)
public String getZooKeeperPassword()
public void setZooKeeperPassword(String zooKeeperPassword)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultComponent
Exception
Apache Camel