org.apache.activemq.camel
Class CamelQueue
java.lang.Object
org.apache.activemq.camel.CamelDestination
org.apache.activemq.camel.CamelQueue
- All Implemented Interfaces:
- Destination, Queue, CustomDestination, org.apache.camel.CamelContextAware
public class CamelQueue
- extends CamelDestination
- implements Queue
A JMS Queue
object which refers to a Camel endpoint
- Version:
- $Revision: $
Methods inherited from class org.apache.activemq.camel.CamelDestination |
createConsumer, createConsumer, createDurableSubscriber, createProducer, createPublisher, createSubscriber, getBinding, getCamelContext, getEndpoint, getUri, resolveCamelContext, resolveEndpoint, setBinding, setCamelContext, setEndpoint, setUri, toString |
CamelQueue
public CamelQueue(String uri)
getQueueName
public String getQueueName()
throws JMSException
- Specified by:
getQueueName
in interface Queue
- Throws:
JMSException
createSender
public QueueSender createSender(ActiveMQSession session)
throws JMSException
- Specified by:
createSender
in interface CustomDestination
- Overrides:
createSender
in class CamelDestination
- Throws:
JMSException
createReceiver
public QueueReceiver createReceiver(ActiveMQSession session,
String messageSelector)
- Specified by:
createReceiver
in interface CustomDestination
- Overrides:
createReceiver
in class CamelDestination
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.