org.apache.camel.component.routebox.seda
Class RouteboxSedaConsumer

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.component.routebox.RouteboxServiceSupport
          org.apache.camel.component.routebox.seda.RouteboxSedaConsumer

All Implemented Interfaces:

Runnable, 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 RouteboxSedaConsumer
extends RouteboxServiceSupport
implements RouteboxConsumer, Runnable, org.apache.camel.spi.ShutdownAware

Field Summary

protected org.apache.camel.AsyncProcessor	processor
protected org.apache.camel.ProducerTemplate	producer

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

RouteboxSedaConsumer(RouteboxSedaEndpoint endpoint, org.apache.camel.Processor processor)

Method Summary

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 forced)
void	run()
void	setProcessor(org.apache.camel.AsyncProcessor processor)

Methods inherited from class org.apache.camel.component.routebox.RouteboxServiceSupport

doStartInnerContext, doStopInnerContext, getExceptionHandler, getExecutor, getRouteboxEndpoint, isStartedInnerContext, setExceptionHandler, setExecutor, setRouteboxEndpoint, setStartedInnerContext

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, 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

Field Detail

processor

protected org.apache.camel.AsyncProcessor processor

producer

protected org.apache.camel.ProducerTemplate producer

Constructor Detail

RouteboxSedaConsumer

public RouteboxSedaConsumer(RouteboxSedaEndpoint endpoint,
                            org.apache.camel.Processor processor)

Method Detail

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

run

public void run()

Specified by:

run in interface Runnable

getEndpoint

public org.apache.camel.Endpoint getEndpoint()

Specified by:

getEndpoint in interface org.apache.camel.Consumer

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

setProcessor

public void setProcessor(org.apache.camel.AsyncProcessor processor)

getProcessor

public org.apache.camel.AsyncProcessor getProcessor()