@ManagedResource(description="Managed ZooKeeper Master Endpoint") @UriEndpoint(firstVersion="2.19.0", scheme="zookeeper-master", syntax="zookeeper-master:groupName:consumerEndpointUri", consumerClass=MasterConsumer.class, consumerOnly=true, title="ZooKeeper Master", lenientProperties=true, label="clustering") public class MasterEndpoint extends org.apache.camel.impl.DefaultEndpoint implements org.apache.camel.DelegateEndpoint
Constructor and Description |
---|
MasterEndpoint(String uri,
MasterComponent component,
String groupName,
String consumerEndpointUri) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
MasterComponent |
getComponent() |
org.apache.camel.Endpoint |
getConsumerEndpoint() |
String |
getConsumerEndpointUri() |
org.apache.camel.Endpoint |
getEndpoint() |
String |
getGroupName() |
boolean |
isLenientProperties() |
boolean |
isSingleton() |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, 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, String groupName, String consumerEndpointUri)
public org.apache.camel.Endpoint getEndpoint()
getEndpoint
in interface org.apache.camel.DelegateEndpoint
public org.apache.camel.Endpoint getConsumerEndpoint()
@ManagedAttribute(description="The consumer endpoint url to use in master/slave mode", mask=true) public String getConsumerEndpointUri()
@ManagedAttribute(description="The name of the cluster group to use") public String getGroupName()
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
public MasterComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
Apache Camel