org.apache.camel.component.disruptor
Class DisruptorConsumer

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.component.disruptor.DisruptorConsumer

All Implemented Interfaces:

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 DisruptorConsumer
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.Consumer, org.apache.camel.SuspendableService, org.apache.camel.spi.ShutdownAware

A Consumer for the Disruptor component.

Field Summary

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

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

Constructor Summary

DisruptorConsumer(DisruptorEndpoint endpoint, org.apache.camel.Processor processor)

Method Summary

boolean	deferShutdown(org.apache.camel.ShutdownRunningTask shutdownRunningTask)
protected void	doResume()
protected void	doStart()
protected void	doStop()
protected void	doSuspend()
DisruptorEndpoint	getEndpoint()
org.apache.camel.spi.ExceptionHandler	getExceptionHandler()
int	getPendingExchangesSize()
void	prepareShutdown(boolean forced)
void	setExceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
String	toString()

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

doShutdown, 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, wait, wait, wait

Methods inherited from interface org.apache.camel.SuspendableService

isSuspended, resume, suspend

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

DisruptorConsumer

public DisruptorConsumer(DisruptorEndpoint endpoint,
                         org.apache.camel.Processor processor)

Method Detail

getExceptionHandler

public org.apache.camel.spi.ExceptionHandler getExceptionHandler()

setExceptionHandler

public void setExceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)

getEndpoint

public DisruptorEndpoint getEndpoint()

Specified by:

getEndpoint in interface org.apache.camel.Consumer

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

doSuspend

protected void doSuspend()
                  throws Exception

Overrides:

doSuspend in class org.apache.camel.support.ServiceSupport

Throws:

Exception

doResume

protected void doResume()
                 throws Exception

Overrides:

doResume in class org.apache.camel.support.ServiceSupport

Throws:

Exception

deferShutdown

public boolean deferShutdown(org.apache.camel.ShutdownRunningTask shutdownRunningTask)

Specified by:

deferShutdown in interface org.apache.camel.spi.ShutdownAware

prepareShutdown

public void prepareShutdown(boolean forced)

Specified by:

prepareShutdown in interface org.apache.camel.spi.ShutdownPrepared

getPendingExchangesSize

public int getPendingExchangesSize()

Specified by:

getPendingExchangesSize in interface org.apache.camel.spi.ShutdownAware

toString

public String toString()

Overrides:

toString in class Object