org.apache.camel.component.queue
Class QueueConsumer<E extends Exchange>
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.component.queue.QueueConsumer<E>
- All Implemented Interfaces:
- Runnable, Consumer<E>, Service
public class QueueConsumer<E extends Exchange>
- extends ServiceSupport
- implements Consumer<E>, Runnable
- Version:
- $Revision: 553477 $
QueueConsumer
public QueueConsumer(QueueEndpoint<E> endpoint,
Processor processor)
toString
public String toString()
- Overrides:
toString
in class Object
run
public void run()
- Specified by:
run
in interface Runnable
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
Copyright © 2007 Apache Software Foundation. All Rights Reserved.