public abstract class ZKComponentSupport extends org.apache.camel.impl.DefaultComponent implements Callable<org.apache.curator.framework.CuratorFramework>
Constructor and Description |
---|
ZKComponentSupport() |
Modifier and Type | Method and Description |
---|---|
org.apache.curator.framework.CuratorFramework |
call() |
io.fabric8.groups.Group<CamelNodeState> |
createGroup(String path) |
protected void |
doStart() |
protected void |
doStop() |
org.apache.curator.framework.CuratorFramework |
getCurator() |
int |
getMaximumConnectionTimeout() |
String |
getZooKeeperPassword() |
String |
getZooKeeperUrl() |
boolean |
isShouldCloseZkClient() |
void |
setCurator(org.apache.curator.framework.CuratorFramework curator) |
void |
setMaximumConnectionTimeout(int maximumConnectionTimeout) |
void |
setShouldCloseZkClient(boolean shouldCloseZkClient) |
void |
setZooKeeperPassword(String zooKeeperPassword) |
void |
setZooKeeperUrl(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 io.fabric8.groups.Group<CamelNodeState> createGroup(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 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
public org.apache.curator.framework.CuratorFramework call() throws Exception
Copyright © 2011–2014 Red Hat. All rights reserved.