public class CamelQueue extends CamelDestination implements Queue
Queue
object which refers to a Camel endpointConstructor 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, toString
public CamelQueue(String uri)
public String getQueueName() throws JMSException
getQueueName
in interface Queue
JMSException
public QueueSender createSender(ActiveMQSession session) throws JMSException
createSender
in interface CustomDestination
createSender
in class CamelDestination
JMSException
public QueueReceiver createReceiver(ActiveMQSession session, String messageSelector)
createReceiver
in interface CustomDestination
createReceiver
in class CamelDestination
Copyright © 2005–2015 FuseSource, Corp.. All rights reserved.