org.apache.activemq.camel

Class CamelQueueReceiver

java.lang.Object

org.apache.activemq.camel.CamelMessageConsumer

org.apache.activemq.camel.CamelQueueReceiver

All Implemented Interfaces:

javax.jms.MessageConsumer, javax.jms.QueueReceiver

public class CamelQueueReceiver
extends CamelMessageConsumer
implements javax.jms.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, java.lang.String name)

Method Summary

Methods

Modifier and Type	Method and Description
javax.jms.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,
                  java.lang.String name)

Method Detail

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException

Gets the Queue associated with this queue receiver.

Specified by:

getQueue in interface javax.jms.QueueReceiver

Returns:

this receiver's Queue

Throws:

javax.jms.JMSException - if the JMS provider fails to get the queue for this queue receiver due to some internal error.