public class DirectConsumer extends DefaultConsumer implements ShutdownAware, Suspendable
logshutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
DirectConsumer(Endpoint endpoint,
Processor processor) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
deferShutdown(ShutdownRunningTask shutdownRunningTask)
To defer shutdown during first phase of shutdown.
|
protected void |
doResume()
Implementations override this method to support customized suspend/resume.
|
protected void |
doStart()
Implementations override this method to support customized start/stop.
|
protected void |
doStop()
Implementations override this method to support customized start/stop.
|
protected void |
doSuspend()
Implementations override this method to support customized suspend/resume.
|
DirectEndpoint |
getEndpoint()
Gets the endpoint associated with an object.
|
int |
getPendingExchangesSize()
Gets the number of pending exchanges.
|
void |
prepareShutdown(boolean suspendOnly,
boolean forced)
Prepares for stop/shutdown.
|
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toStringdoShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic DirectConsumer(Endpoint endpoint, Processor processor)
public DirectEndpoint getEndpoint()
EndpointAwareProducer
or for consuming from for components like Consumer or RoutegetEndpoint in interface EndpointAwaregetEndpoint in class DefaultConsumerprotected void doStart() throws Exception
ServiceSupportServiceSupport.doStop() for more details.doStart in class DefaultConsumerExceptionServiceSupport.doStop()protected void doStop() throws Exception
ServiceSupportServiceSupport.doStop() method when
the service is being stopped. This method will also be invoked
if the service is still in uninitialized state (eg has not
been started). The method is always called to allow the service
to do custom logic when the service is being stopped, such as when
CamelContext is shutting down.doStop in class DefaultConsumerExceptionServiceSupport.doStart()protected void doSuspend() throws Exception
ServiceSupportdoSuspend in class ServiceSupportExceptionprotected void doResume() throws Exception
ServiceSupportdoResume in class ServiceSupportExceptionpublic boolean deferShutdown(ShutdownRunningTask shutdownRunningTask)
ShutdownAwareSedaConsumer.deferShutdown in interface ShutdownAwareshutdownRunningTask - the configured option for how to act when shutting down running tasks.public int getPendingExchangesSize()
ShutdownAwareExchange which are pending.
For example the SedaConsumer.
Return zero to indicate no pending exchanges and therefore ready to shutdown.getPendingExchangesSize in interface ShutdownAwarepublic void prepareShutdown(boolean suspendOnly, boolean forced)
ShutdownPreparedShutdownStrategy supports preparing for shutdown using two steps.
First a regular preparation, where the given forced parameter will be false.
And if the shutdown times out, then the ShutdownStrategy performs a more aggressive
shutdown, calling this method a second time with true for the given forced parameter.
For example by graceful stopping any threads or the likes.
In addition a service can also be suspended (not stopped), and when this happens the parameter
suspendOnly has the value true. This can be used to prepare the service
for suspension, such as marking a worker thread to skip action.
For forced shutdown, then the service is expected to aggressively shutdown any child services, such
as thread pools etc. This is the last chance it has to perform such duties.prepareShutdown in interface ShutdownPreparedsuspendOnly - true if the intention is to only suspend the service, and not stop/shutdown the service.forced - true is forcing a more aggressive shutdown, false is for preparing to shutdown.Apache Camel