public class CamelQueueReceiver extends CamelMessageConsumer implements javax.jms.QueueReceiver
QueueReceiver
which consumes message exchanges from a
Camel Endpoint
Constructor and Description |
---|
CamelQueueReceiver(CamelQueue destination,
org.apache.camel.Endpoint endpoint,
org.apache.activemq.ActiveMQSession session,
String name) |
Modifier and Type | Method and Description |
---|---|
javax.jms.Queue |
getQueue()
Gets the
Queue associated with this queue receiver. |
checkClosed, close, createConsumer, createMessage, getDestination, getEndpoint, getMessageListener, getMessageSelector, getPollingConsumer, getSession, isNoLocal, receive, receive, receiveNoWait, setMessageListener
public CamelQueueReceiver(CamelQueue destination, org.apache.camel.Endpoint endpoint, org.apache.activemq.ActiveMQSession session, String name)
public javax.jms.Queue getQueue() throws javax.jms.JMSException
Queue
associated with this queue receiver.getQueue
in interface javax.jms.QueueReceiver
Queue
javax.jms.JMSException
- if the JMS provider fails to get the queue for this queue
receiver due to some internal error.Apache Camel