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