org.apache.activemq.camel
Class CamelQueueReceiver

java.lang.Object
  extended by org.apache.activemq.camel.CamelMessageConsumer
      extended by 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
CamelQueueReceiver(CamelQueue destination, org.apache.camel.Endpoint endpoint, ActiveMQSession session, String name)
           
 
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
 
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.


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.