public class FabricLocatorEndpoint extends org.apache.camel.impl.DefaultEndpoint implements GroupListener<CamelNodeState>
GroupListener.GroupEvent
Constructor and Description |
---|
FabricLocatorEndpoint(java.lang.String uri,
FabricComponent component,
java.lang.String singletonId) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.processor.loadbalancer.LoadBalancer |
createLoadBalancer() |
org.apache.camel.Producer |
createProducer() |
FabricComponent |
getComponent() |
LoadBalancerFactory |
getLoadBalancerFactory() |
org.apache.camel.Processor |
getProcessor(java.lang.String uri) |
void |
groupEvent(Group<CamelNodeState> group,
GroupListener.GroupEvent event) |
boolean |
isSingleton() |
void |
reSubscribeToZK() |
void |
setLoadBalancerFactory(LoadBalancerFactory loadBalancerFactory) |
void |
start() |
void |
stop() |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString
public FabricLocatorEndpoint(java.lang.String uri, FabricComponent component, java.lang.String singletonId)
public void groupEvent(Group<CamelNodeState> group, GroupListener.GroupEvent event)
groupEvent
in interface GroupListener<CamelNodeState>
public org.apache.camel.Producer createProducer() throws java.lang.Exception
createProducer
in interface org.apache.camel.Endpoint
java.lang.Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws java.lang.Exception
createConsumer
in interface org.apache.camel.Endpoint
java.lang.Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public void start() throws java.lang.Exception
start
in interface org.apache.camel.Service
start
in class org.apache.camel.support.ServiceSupport
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface org.apache.camel.Service
stop
in class org.apache.camel.support.ServiceSupport
java.lang.Exception
public org.apache.camel.Processor getProcessor(java.lang.String uri) throws java.net.URISyntaxException
java.net.URISyntaxException
public FabricComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
public LoadBalancerFactory getLoadBalancerFactory()
public void setLoadBalancerFactory(LoadBalancerFactory loadBalancerFactory)
public org.apache.camel.processor.loadbalancer.LoadBalancer createLoadBalancer()
public void reSubscribeToZK()
Copyright © 2016 Red Hat. All Rights Reserved.