public class DisruptorConsumer
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.Consumer, org.apache.camel.Suspendable, org.apache.camel.spi.ShutdownAware
Constructor and Description |
---|
DisruptorConsumer(DisruptorEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
boolean |
deferShutdown(org.apache.camel.ShutdownRunningTask shutdownRunningTask) |
protected void |
doResume() |
protected void |
doStart() |
protected void |
doStop() |
protected void |
doSuspend() |
DisruptorEndpoint |
getEndpoint() |
org.apache.camel.spi.ExceptionHandler |
getExceptionHandler() |
int |
getPendingExchangesSize() |
void |
prepareShutdown(boolean suspendOnly,
boolean forced) |
void |
setExceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler) |
String |
toString() |
doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public DisruptorConsumer(DisruptorEndpoint endpoint, org.apache.camel.Processor processor)
public org.apache.camel.spi.ExceptionHandler getExceptionHandler()
public void setExceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
public DisruptorEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.support.ServiceSupport
Exception
protected void doSuspend() throws Exception
doSuspend
in class org.apache.camel.support.ServiceSupport
Exception
protected void doResume() throws Exception
doResume
in class org.apache.camel.support.ServiceSupport
Exception
public boolean deferShutdown(org.apache.camel.ShutdownRunningTask shutdownRunningTask)
deferShutdown
in interface org.apache.camel.spi.ShutdownAware
public void prepareShutdown(boolean suspendOnly, boolean forced)
prepareShutdown
in interface org.apache.camel.spi.ShutdownPrepared
public int getPendingExchangesSize()
getPendingExchangesSize
in interface org.apache.camel.spi.ShutdownAware
Apache Camel