public class RouteboxSedaConsumer extends RouteboxServiceSupport implements RouteboxConsumer, Runnable, org.apache.camel.spi.ShutdownAware
Modifier and Type | Field and Description |
---|---|
protected org.apache.camel.AsyncProcessor |
processor |
protected org.apache.camel.ProducerTemplate |
producer |
Constructor and Description |
---|
RouteboxSedaConsumer(RouteboxSedaEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
boolean |
deferShutdown(org.apache.camel.ShutdownRunningTask shutdownRunningTask) |
protected void |
doStart() |
protected void |
doStop() |
org.apache.camel.Endpoint |
getEndpoint() |
int |
getPendingExchangesSize() |
org.apache.camel.AsyncProcessor |
getProcessor() |
void |
prepareShutdown(boolean suspendOnly,
boolean forced) |
void |
run() |
void |
setProcessor(org.apache.camel.AsyncProcessor processor) |
doStartInnerContext, doStopInnerContext, getExceptionHandler, getExecutor, getRouteboxEndpoint, isStartedInnerContext, setExceptionHandler, setExecutor, setRouteboxEndpoint, setStartedInnerContext
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected org.apache.camel.AsyncProcessor processor
protected org.apache.camel.ProducerTemplate producer
public RouteboxSedaConsumer(RouteboxSedaEndpoint 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
public org.apache.camel.Endpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
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 void setProcessor(org.apache.camel.AsyncProcessor processor)
public org.apache.camel.AsyncProcessor getProcessor()
Apache Camel