org.apache.activemq.camel
Class CamelTopic
java.lang.Object
org.apache.activemq.camel.CamelDestination
org.apache.activemq.camel.CamelTopic
- All Implemented Interfaces:
- Destination, Topic, CustomDestination, org.apache.camel.CamelContextAware
public class CamelTopic
- extends CamelDestination
- implements Topic
A JMS Topic
object which refers to a Camel endpoint
- Version:
- $Revision: $
Methods inherited from class org.apache.activemq.camel.CamelDestination |
createConsumer, createConsumer, createProducer, createReceiver, createSender, createSubscriber, getBinding, getCamelContext, getEndpoint, getUri, resolveCamelContext, resolveEndpoint, setBinding, setCamelContext, setEndpoint, setUri, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CamelTopic
public CamelTopic(String uri)
getTopicName
public String getTopicName()
throws JMSException
- Specified by:
getTopicName
in interface Topic
- Throws:
JMSException
createPublisher
public TopicPublisher createPublisher(ActiveMQSession session)
throws JMSException
- Specified by:
createPublisher
in interface CustomDestination
- Overrides:
createPublisher
in class CamelDestination
- Throws:
JMSException
createDurableSubscriber
public TopicSubscriber createDurableSubscriber(ActiveMQSession session,
String name,
String messageSelector,
boolean noLocal)
- Specified by:
createDurableSubscriber
in interface CustomDestination
- Overrides:
createDurableSubscriber
in class CamelDestination
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.