org.apache.activemq.camel
Class CamelQueueReceiver
java.lang.Object
org.apache.activemq.camel.CamelMessageConsumer
org.apache.activemq.camel.CamelQueueReceiver
- All Implemented Interfaces:
- MessageConsumer, QueueReceiver
public class CamelQueueReceiver
- extends CamelMessageConsumer
- implements QueueReceiver
A JMS QueueReceiver
which consumes message exchanges from a
Camel Endpoint
- Version:
- $Revision: $
Method Summary |
Queue |
getQueue()
Gets the Queue associated with this queue receiver. |
Methods inherited from class org.apache.activemq.camel.CamelMessageConsumer |
checkClosed, close, createConsumer, createMessage, getDestination, getEndpoint, getMessageListener, getMessageSelector, getPollingConsumer, getSession, isNoLocal, receive, receive, receiveNoWait, setMessageListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CamelQueueReceiver
public CamelQueueReceiver(CamelQueue destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session,
String name)
getQueue
public Queue getQueue()
throws JMSException
- Gets the
Queue
associated with this queue receiver.
- Specified by:
getQueue
in interface QueueReceiver
- Returns:
- this receiver's
Queue
- Throws:
JMSException
- if the JMS provider fails to get the queue for this queue
receiver due to some internal error.
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.