org.apache.camel.impl
Class ConsumerCache
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.impl.ConsumerCache
- All Implemented Interfaces:
- Service
public class ConsumerCache
- extends ServiceSupport
Cache containing created Consumer.
- Version:
- $Revision: 789593 $
| Methods inherited from class org.apache.camel.impl.ServiceSupport |
addChildService, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, start, stop |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConsumerCache
public ConsumerCache()
ConsumerCache
public ConsumerCache(Map<String,PollingConsumer> cache)
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)
doStop
protected void doStop()
throws Exception
- Specified by:
doStop in class ServiceSupport
- Throws:
Exception
doStart
protected void doStart()
throws Exception
- Specified by:
doStart in class ServiceSupport
- Throws:
Exception
Apache CAMEL