public class VmConsumer extends SedaConsumer implements CamelContextAware
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
VmConsumer(VmEndpoint endpoint,
Processor processor) |
| Modifier and Type | Method and Description |
|---|---|
CamelContext |
getCamelContext()
Get the
CamelContext |
protected Exchange |
prepareExchange(Exchange exchange)
Strategy to prepare exchange for being processed by this consumer
|
void |
setCamelContext(CamelContext camelContext)
Injects the
CamelContext |
deferShutdown, doResume, doRun, doShutdown, doStart, doStop, doSuspend, getEndpoint, getExceptionHandler, getPendingExchangesSize, getProcessor, isRunAllowed, prepareShutdown, run, sendToConsumers, setExceptionHandler, toStringgetStatus, getVersion, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic VmConsumer(VmEndpoint endpoint, Processor processor)
public CamelContext getCamelContext()
CamelContextAwareCamelContextgetCamelContext in interface CamelContextAwarepublic void setCamelContext(CamelContext camelContext)
CamelContextAwareCamelContextsetCamelContext in interface CamelContextAwarecamelContext - the Camel contextprotected Exchange prepareExchange(Exchange exchange)
prepareExchange in class SedaConsumerexchange - the exchangeApache Camel