public class FabricLocatorEndpoint extends org.apache.camel.impl.DefaultEndpoint implements io.fabric8.groups.GroupListener<CamelNodeState>
Constructor and Description |
---|
FabricLocatorEndpoint(String uri,
FabricComponent component,
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(String uri) |
void |
groupEvent(io.fabric8.groups.Group<CamelNodeState> group,
io.fabric8.groups.GroupListener.GroupEvent event) |
boolean |
isSingleton() |
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, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
public FabricLocatorEndpoint(String uri, FabricComponent component, String singletonId)
public void groupEvent(io.fabric8.groups.Group<CamelNodeState> group, io.fabric8.groups.GroupListener.GroupEvent event)
groupEvent
in interface io.fabric8.groups.GroupListener<CamelNodeState>
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public void start() throws Exception
start
in interface org.apache.camel.Service
start
in class org.apache.camel.support.ServiceSupport
Exception
public void stop() throws Exception
stop
in interface org.apache.camel.Service
stop
in class org.apache.camel.support.ServiceSupport
Exception
public org.apache.camel.Processor getProcessor(String uri) throws URISyntaxException
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()
Copyright © 2011–2014 Red Hat. All rights reserved.