@ManagedResource(description="Managed Master Consumer")
public class MasterConsumer
extends org.apache.camel.impl.DefaultConsumer
CamelClusterView
has
the leadership.Constructor and Description |
---|
MasterConsumer(MasterEndpoint masterEndpoint,
org.apache.camel.Processor processor,
org.apache.camel.cluster.CamelClusterService clusterService) |
Modifier and Type | Method and Description |
---|---|
protected void |
doResume() |
protected void |
doStart() |
protected void |
doStop() |
protected void |
doSuspend() |
boolean |
isMaster() |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public MasterConsumer(MasterEndpoint masterEndpoint, org.apache.camel.Processor processor, org.apache.camel.cluster.CamelClusterService clusterService)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doResume() throws Exception
doResume
in class org.apache.camel.support.ServiceSupport
Exception
protected void doSuspend() throws Exception
doSuspend
in class org.apache.camel.support.ServiceSupport
Exception
@ManagedAttribute(description="Are we the master") public boolean isMaster()
Apache Camel