public class FabricComponent extends ZKComponentSupport
Constructor and Description |
---|
FabricComponent() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.camel.Endpoint |
createEndpoint(java.lang.String uri,
java.lang.String remaining,
java.util.Map<java.lang.String,java.lang.Object> params) |
protected void |
doStart() |
protected void |
doStop() |
int |
getCacheSize() |
protected java.lang.String |
getFabricPath(java.lang.String name) |
LoadBalancerFactory |
getLoadBalancerFactory() |
org.apache.camel.impl.ProducerCache |
getProducerCache() |
java.lang.String |
getZkRoot() |
protected java.lang.String |
replaceAnyIpAddress(java.lang.String uri) |
void |
setCacheSize(int cacheSize) |
void |
setLoadBalancerFactory(LoadBalancerFactory loadBalancerFactory) |
void |
setProducerCache(org.apache.camel.impl.ProducerCache producerCache) |
void |
setZkRoot(java.lang.String zkRoot) |
call, createGroup, getCurator, getMaximumConnectionTimeout, getZooKeeperPassword, getZooKeeperUrl, isShouldCloseZkClient, registerAsListener, setCurator, setMaximumConnectionTimeout, setShouldCloseZkClient, setZooKeeperPassword, setZooKeeperUrl, stateChanged
afterConfiguration, createComponentConfiguration, createConfiguration, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
public java.lang.String getZkRoot()
public void setZkRoot(java.lang.String zkRoot)
public int getCacheSize()
public void setCacheSize(int cacheSize)
public org.apache.camel.impl.ProducerCache getProducerCache()
public void setProducerCache(org.apache.camel.impl.ProducerCache producerCache)
public LoadBalancerFactory getLoadBalancerFactory()
public void setLoadBalancerFactory(LoadBalancerFactory loadBalancerFactory)
protected void doStart() throws java.lang.Exception
doStart
in class ZKComponentSupport
java.lang.Exception
protected void doStop() throws java.lang.Exception
doStop
in class ZKComponentSupport
java.lang.Exception
protected org.apache.camel.Endpoint createEndpoint(java.lang.String uri, java.lang.String remaining, java.util.Map<java.lang.String,java.lang.Object> params) throws java.lang.Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
java.lang.Exception
protected java.lang.String getFabricPath(java.lang.String name)
protected java.lang.String replaceAnyIpAddress(java.lang.String uri)
Copyright © 2016 Red Hat. All Rights Reserved.