org.apache.camel.component.kestrel
Class KestrelConsumer

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultConsumer
          extended by org.apache.camel.component.kestrel.KestrelConsumer
All Implemented Interfaces:
org.apache.camel.Consumer, org.apache.camel.RouteAware, 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 KestrelConsumer
extends org.apache.camel.impl.DefaultConsumer
implements org.apache.camel.spi.ShutdownAware

A Camel consumer that polls a kestrel queue.


Field Summary
 
Fields inherited from class org.apache.camel.impl.DefaultConsumer
log
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
KestrelConsumer(KestrelEndpoint endpoint, org.apache.camel.Processor processor, net.spy.memcached.MemcachedClient memcachedClient)
           
 
Method Summary
 boolean deferShutdown(org.apache.camel.ShutdownRunningTask shutdownRunningTask)
           
protected  void doStart()
           
protected  void doStop()
           
 int getPendingExchangesSize()
           
 void prepareShutdown(boolean forced)
           
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
 
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, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

KestrelConsumer

public KestrelConsumer(KestrelEndpoint endpoint,
                       org.apache.camel.Processor processor,
                       net.spy.memcached.MemcachedClient memcachedClient)
Method Detail

doStart

protected void doStart()
                throws Exception
Overrides:
doStart in class org.apache.camel.impl.DefaultConsumer
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Overrides:
doStop in class org.apache.camel.impl.DefaultConsumer
Throws:
Exception

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


Apache Camel