org.apache.camel.impl
Class ConsumerCache

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.ConsumerCache
All Implemented Interfaces:
Service, ShutdownableService

public class ConsumerCache
extends ServiceSupport

Cache containing created Consumer.

Version:
$Revision: 19027 $

Constructor Summary
ConsumerCache(CamelContext camelContext)
           
ConsumerCache(CamelContext camelContext, int maximumCacheSize)
           
ConsumerCache(CamelContext camelContext, Map<String,PollingConsumer> cache)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop()
           
 CamelContext getCamelContext()
           
 PollingConsumer getConsumer(Endpoint endpoint)
           
 Exchange receive(Endpoint endpoint)
           
 Exchange receive(Endpoint endpoint, long timeout)
           
 Exchange receiveNoWait(Endpoint endpoint)
           
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConsumerCache

public ConsumerCache(CamelContext camelContext)

ConsumerCache

public ConsumerCache(CamelContext camelContext,
                     int maximumCacheSize)

ConsumerCache

public ConsumerCache(CamelContext camelContext,
                     Map<String,PollingConsumer> cache)
Method Detail

getConsumer

public PollingConsumer getConsumer(Endpoint endpoint)

receive

public Exchange receive(Endpoint endpoint)

receive

public Exchange receive(Endpoint endpoint,
                        long timeout)

receiveNoWait

public Exchange receiveNoWait(Endpoint endpoint)

getCamelContext

public CamelContext getCamelContext()

doStart

protected void doStart()
                throws Exception
Specified by:
doStart in class ServiceSupport
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Specified by:
doStop in class ServiceSupport
Throws:
Exception


Apache CAMEL