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

Constructor Summary

Constructors

Constructor and Description
CamelQueueReceiver(CamelQueue destination, org.apache.camel.Endpoint endpoint, ActiveMQSession session, String name)

Method Summary

Modifier and Type	Method and Description
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

Methods inherited from interface javax.jms.MessageConsumer

close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener

Constructor Detail

CamelQueueReceiver

public CamelQueueReceiver(CamelQueue destination,
                          org.apache.camel.Endpoint endpoint,
                          ActiveMQSession session,
                          String name)

Method Detail

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.