Class DisruptorConsumer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.component.disruptor.DisruptorConsumer
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.Consumer
,org.apache.camel.EndpointAware
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.ShutdownAware
,org.apache.camel.spi.ShutdownPrepared
,org.apache.camel.StatefulService
,org.apache.camel.Suspendable
,org.apache.camel.SuspendableService
public class DisruptorConsumer extends org.apache.camel.support.service.ServiceSupport implements org.apache.camel.Consumer, org.apache.camel.Suspendable, org.apache.camel.spi.ShutdownAware
A Consumer for the Disruptor component.
-
-
Constructor Summary
Constructors Constructor Description DisruptorConsumer(DisruptorEndpoint endpoint, org.apache.camel.Processor processor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
org.apache.camel.AsyncProcessor
getProcessor()
void
prepareShutdown(boolean suspendOnly, boolean forced)
void
setExceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
String
toString()
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doShutdown, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Constructor Detail
-
DisruptorConsumer
public DisruptorConsumer(DisruptorEndpoint endpoint, org.apache.camel.Processor processor)
-
-
Method Detail
-
getProcessor
public org.apache.camel.AsyncProcessor getProcessor()
- Specified by:
getProcessor
in interfaceorg.apache.camel.Consumer
-
getExceptionHandler
public org.apache.camel.spi.ExceptionHandler getExceptionHandler()
-
setExceptionHandler
public void setExceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
-
getEndpoint
public DisruptorEndpoint getEndpoint()
- Specified by:
getEndpoint
in interfaceorg.apache.camel.EndpointAware
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doSuspend
protected void doSuspend() throws Exception
- Overrides:
doSuspend
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doResume
protected void doResume() throws Exception
- Overrides:
doResume
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
deferShutdown
public boolean deferShutdown(org.apache.camel.ShutdownRunningTask shutdownRunningTask)
- Specified by:
deferShutdown
in interfaceorg.apache.camel.spi.ShutdownAware
-
prepareShutdown
public void prepareShutdown(boolean suspendOnly, boolean forced)
- Specified by:
prepareShutdown
in interfaceorg.apache.camel.spi.ShutdownPrepared
-
getPendingExchangesSize
public int getPendingExchangesSize()
- Specified by:
getPendingExchangesSize
in interfaceorg.apache.camel.spi.ShutdownAware
-
-