public class CamelQueue extends CamelDestination implements javax.jms.Queue
Queue
object which refers to a Camel endpointConstructor and Description |
---|
CamelQueue(String uri) |
Modifier and Type | Method and Description |
---|---|
javax.jms.QueueReceiver |
createReceiver(org.apache.activemq.ActiveMQSession session,
String messageSelector) |
javax.jms.QueueSender |
createSender(org.apache.activemq.ActiveMQSession session) |
String |
getQueueName() |
createConsumer, createConsumer, createDurableSubscriber, createProducer, createPublisher, createSubscriber, getBinding, getCamelContext, getEndpoint, getUri, resolveCamelContext, resolveEndpoint, setBinding, setCamelContext, setEndpoint, setUri, toString
public CamelQueue(String uri)
public String getQueueName() throws javax.jms.JMSException
getQueueName
in interface javax.jms.Queue
javax.jms.JMSException
public javax.jms.QueueSender createSender(org.apache.activemq.ActiveMQSession session) throws javax.jms.JMSException
createSender
in interface org.apache.activemq.CustomDestination
createSender
in class CamelDestination
javax.jms.JMSException
public javax.jms.QueueReceiver createReceiver(org.apache.activemq.ActiveMQSession session, String messageSelector)
createReceiver
in interface org.apache.activemq.CustomDestination
createReceiver
in class CamelDestination
Apache Camel