public class RouteboxDirectConsumer extends RouteboxServiceSupport implements RouteboxConsumer, org.apache.camel.spi.ShutdownAware, org.apache.camel.Suspendable
Modifier and Type | Field and Description |
---|---|
protected org.apache.camel.ProducerTemplate |
producer |
Constructor and Description |
---|
RouteboxDirectConsumer(RouteboxDirectEndpoint 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() |
org.apache.camel.AsyncProcessor |
getAsyncProcessor()
Provides an
AsyncProcessor interface to the configured
processor on the consumer. |
RouteboxDirectEndpoint |
getEndpoint() |
int |
getPendingExchangesSize() |
org.apache.camel.Processor |
getProcessor() |
void |
prepareShutdown(boolean suspendOnly,
boolean forced) |
doStartInnerContext, doStopInnerContext, getExceptionHandler, getExecutor, getRouteboxEndpoint, isStartedInnerContext, setExceptionHandler, setExecutor, setRouteboxEndpoint, setStartedInnerContext
doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public RouteboxDirectConsumer(RouteboxDirectEndpoint endpoint, org.apache.camel.Processor processor)
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 org.apache.camel.AsyncProcessor getAsyncProcessor()
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.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
public RouteboxDirectEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
public org.apache.camel.Processor getProcessor()
Apache Camel