public class KestrelConsumer
extends org.apache.camel.impl.DefaultConsumer
implements org.apache.camel.spi.ShutdownAware
Constructor and Description |
---|
KestrelConsumer(KestrelEndpoint endpoint,
org.apache.camel.Processor processor,
net.spy.memcached.MemcachedClient memcachedClient) |
Modifier and Type | Method and Description |
---|---|
boolean |
deferShutdown(org.apache.camel.ShutdownRunningTask shutdownRunningTask) |
protected void |
doStart() |
protected void |
doStop() |
int |
getPendingExchangesSize() |
void |
prepareShutdown(boolean suspendOnly,
boolean forced) |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public KestrelConsumer(KestrelEndpoint endpoint, org.apache.camel.Processor processor, net.spy.memcached.MemcachedClient memcachedClient)
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
public boolean deferShutdown(org.apache.camel.ShutdownRunningTask shutdownRunningTask)
deferShutdown
in interface org.apache.camel.spi.ShutdownAware
public int getPendingExchangesSize()
getPendingExchangesSize
in interface org.apache.camel.spi.ShutdownAware
public void prepareShutdown(boolean suspendOnly, boolean forced)
prepareShutdown
in interface org.apache.camel.spi.ShutdownPrepared
Apache Camel