public class CamelQueue extends CamelDestination implements Queue
Queue object which refers to a Camel endpoint| Constructor and Description |
|---|
CamelQueue(String uri) |
| Modifier and Type | Method and Description |
|---|---|
QueueReceiver |
createReceiver(ActiveMQSession session,
String messageSelector) |
QueueSender |
createSender(ActiveMQSession session) |
String |
getQueueName() |
createConsumer, createConsumer, createDurableSubscriber, createProducer, createPublisher, createSubscriber, getBinding, getCamelContext, getEndpoint, getUri, resolveCamelContext, resolveEndpoint, setBinding, setCamelContext, setEndpoint, setUri, toStringpublic CamelQueue(String uri)
public String getQueueName() throws JMSException
getQueueName in interface QueueJMSExceptionpublic QueueSender createSender(ActiveMQSession session) throws JMSException
createSender in interface CustomDestinationcreateSender in class CamelDestinationJMSExceptionpublic QueueReceiver createReceiver(ActiveMQSession session, String messageSelector)
createReceiver in interface CustomDestinationcreateReceiver in class CamelDestinationCopyright © 2005–2015 FuseSource, Corp.. All rights reserved.