public class MasterComponent extends ZookeeperComponentSupport
Constructor and Description |
---|
MasterComponent() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> params) |
protected String |
getCamelClusterPath(String name) |
ContainerIdFactory |
getContainerIdFactory() |
String |
getZkRoot() |
void |
setContainerIdFactory(ContainerIdFactory containerIdFactory)
To use a custom ContainerIdFactory for creating container ids.
|
void |
setZkRoot(String zkRoot)
The root path to use in zookeeper where information is stored which nodes are master/slave etc.
|
createGroup, doStart, doStop, getCurator, getMaximumConnectionTimeout, getZooKeeperPassword, getZooKeeperUrl, setCurator, setMaximumConnectionTimeout, setZooKeeperPassword, setZooKeeperUrl
afterConfiguration, createComponentConfiguration, createConfiguration, 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 ContainerIdFactory getContainerIdFactory()
public void setContainerIdFactory(ContainerIdFactory containerIdFactory)
public String getZkRoot()
public void setZkRoot(String zkRoot)
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> params) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
Apache Camel