@ManagedResource(description="Managed Master Endpoint") @UriEndpoint(firstVersion="2.20.0", scheme="master", syntax="master:namespace:delegateUri", consumerClass=MasterConsumer.class, consumerOnly=true, title="Master", lenientProperties=true, label="clustering") public class MasterEndpoint extends org.apache.camel.impl.DefaultEndpoint implements org.apache.camel.DelegateEndpoint
CamelClusterView
has the leadership.Constructor and Description |
---|
MasterEndpoint(String uri,
MasterComponent component,
org.apache.camel.cluster.CamelClusterService clusterService,
String namespace,
String delegateUri) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
org.apache.camel.Endpoint |
getEndpoint() |
String |
getNamespace() |
boolean |
isLenientProperties() |
boolean |
isSingleton() |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public MasterEndpoint(String uri, MasterComponent component, org.apache.camel.cluster.CamelClusterService clusterService, String namespace, String delegateUri)
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 boolean isLenientProperties()
isLenientProperties
in interface org.apache.camel.Endpoint
isLenientProperties
in class org.apache.camel.impl.DefaultEndpoint
@ManagedAttribute(description="The consumer endpoint url to use in master/slave mode", mask=true) public org.apache.camel.Endpoint getEndpoint()
getEndpoint
in interface org.apache.camel.DelegateEndpoint
@ManagedAttribute(description="The name of the cluster namespace/group to use") public String getNamespace()
Apache Camel