public abstract class ZKComponentSupport extends org.apache.camel.impl.DefaultComponent implements java.util.concurrent.Callable<org.apache.curator.framework.CuratorFramework>
Constructor and Description |
---|
ZKComponentSupport() |
Modifier and Type | Method and Description |
---|---|
org.apache.curator.framework.CuratorFramework |
call() |
Group<CamelNodeState> |
createGroup(java.lang.String path) |
protected void |
doStart() |
protected void |
doStop() |
org.apache.curator.framework.CuratorFramework |
getCurator() |
int |
getMaximumConnectionTimeout() |
java.lang.String |
getZooKeeperPassword() |
java.lang.String |
getZooKeeperUrl() |
boolean |
isShouldCloseZkClient() |
void |
setCurator(org.apache.curator.framework.CuratorFramework curator) |
void |
setMaximumConnectionTimeout(int maximumConnectionTimeout) |
void |
setShouldCloseZkClient(boolean shouldCloseZkClient) |
void |
setZooKeeperPassword(java.lang.String zooKeeperPassword) |
void |
setZooKeeperUrl(java.lang.String zooKeeperUrl) |
afterConfiguration, createComponentConfiguration, createConfiguration, createEndpoint, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
public org.apache.curator.framework.CuratorFramework getCurator()
public Group<CamelNodeState> createGroup(java.lang.String path)
public void setCurator(org.apache.curator.framework.CuratorFramework curator)
public boolean isShouldCloseZkClient()
public void setShouldCloseZkClient(boolean shouldCloseZkClient)
public int getMaximumConnectionTimeout()
public void setMaximumConnectionTimeout(int maximumConnectionTimeout)
public java.lang.String getZooKeeperUrl()
public void setZooKeeperUrl(java.lang.String zooKeeperUrl)
public java.lang.String getZooKeeperPassword()
public void setZooKeeperPassword(java.lang.String zooKeeperPassword)
protected void doStart() throws java.lang.Exception
doStart
in class org.apache.camel.impl.DefaultComponent
java.lang.Exception
public org.apache.curator.framework.CuratorFramework call() throws java.lang.Exception
call
in interface java.util.concurrent.Callable<org.apache.curator.framework.CuratorFramework>
java.lang.Exception
protected void doStop() throws java.lang.Exception
doStop
in class org.apache.camel.impl.DefaultComponent
java.lang.Exception
Copyright © 2014 Red Hat. All Rights Reserved.