org.apache.camel.component.routebox.direct
Class RouteboxDirectConsumer
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.component.routebox.RouteboxServiceSupport
org.apache.camel.component.routebox.direct.RouteboxDirectConsumer
- All Implemented Interfaces:
- RouteboxConsumer, org.apache.camel.Consumer, 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.SuspendableService
public class RouteboxDirectConsumer
- extends RouteboxServiceSupport
- implements RouteboxConsumer, org.apache.camel.spi.ShutdownAware, org.apache.camel.SuspendableService
Field Summary |
protected org.apache.camel.ProducerTemplate |
producer
|
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.camel.Service |
start, stop |
Methods inherited from interface org.apache.camel.SuspendableService |
isSuspended, resume, suspend |
producer
protected org.apache.camel.ProducerTemplate producer
RouteboxDirectConsumer
public RouteboxDirectConsumer(RouteboxDirectEndpoint endpoint,
org.apache.camel.Processor processor)
doStart
protected void doStart()
throws Exception
- Specified by:
doStart
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Specified by:
doStop
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
doSuspend
protected void doSuspend()
throws Exception
- Overrides:
doSuspend
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
doResume
protected void doResume()
throws Exception
- Overrides:
doResume
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
getAsyncProcessor
public org.apache.camel.AsyncProcessor getAsyncProcessor()
- Provides an
AsyncProcessor
interface to the configured
processor on the consumer. If the processor does not implement the interface,
it will be adapted so that it does.
deferShutdown
public boolean deferShutdown(org.apache.camel.ShutdownRunningTask shutdownRunningTask)
- Specified by:
deferShutdown
in interface org.apache.camel.spi.ShutdownAware
getPendingExchangesSize
public int getPendingExchangesSize()
- Specified by:
getPendingExchangesSize
in interface org.apache.camel.spi.ShutdownAware
prepareShutdown
public void prepareShutdown(boolean forced)
- Specified by:
prepareShutdown
in interface org.apache.camel.spi.ShutdownPrepared
getEndpoint
public RouteboxDirectEndpoint getEndpoint()
- Specified by:
getEndpoint
in interface org.apache.camel.Consumer
getProcessor
public org.apache.camel.Processor getProcessor()
Apache Camel