public class MasterConsumer
extends org.apache.camel.impl.DefaultConsumer
implements io.fabric8.groups.GroupListener
Constructor and Description |
---|
MasterConsumer(MasterEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected void |
doResume() |
protected void |
doStart() |
protected void |
doStop() |
protected void |
doSuspend() |
void |
groupEvent(io.fabric8.groups.Group group,
io.fabric8.groups.GroupListener.GroupEvent event) |
protected void |
onLockOwned() |
protected void |
stopConsumer() |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
public MasterConsumer(MasterEndpoint endpoint, org.apache.camel.Processor processor)
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
public void groupEvent(io.fabric8.groups.Group group, io.fabric8.groups.GroupListener.GroupEvent event)
groupEvent
in interface io.fabric8.groups.GroupListener
protected void onLockOwned()
Copyright © 2011–2014 Red Hat. All rights reserved.