public class CamelTopicSubscriber extends CamelMessageConsumer implements javax.jms.TopicSubscriber
TopicSubscriber
which consumes message exchanges from a
Camel Endpoint
Constructor and Description |
---|
CamelTopicSubscriber(CamelTopic destination,
org.apache.camel.Endpoint endpoint,
org.apache.activemq.ActiveMQSession session,
String name,
String messageSelector,
boolean noLocal) |
Modifier and Type | Method and Description |
---|---|
boolean |
getNoLocal()
Gets the
NoLocal attribute for this subscriber. |
javax.jms.Topic |
getTopic()
Gets the
Topic associated with this subscriber. |
checkClosed, close, createConsumer, createMessage, getDestination, getEndpoint, getMessageListener, getMessageSelector, getPollingConsumer, getSession, isNoLocal, receive, receive, receiveNoWait, setMessageListener
public CamelTopicSubscriber(CamelTopic destination, org.apache.camel.Endpoint endpoint, org.apache.activemq.ActiveMQSession session, String name, String messageSelector, boolean noLocal)
public javax.jms.Topic getTopic() throws javax.jms.JMSException
Topic
associated with this subscriber.getTopic
in interface javax.jms.TopicSubscriber
Topic
javax.jms.JMSException
- if the JMS provider fails to get the topic for this topic
subscriber due to some internal error.public boolean getNoLocal() throws javax.jms.JMSException
NoLocal
attribute for this subscriber. The
default value for this attribute is false.getNoLocal
in interface javax.jms.TopicSubscriber
javax.jms.JMSException
- if the JMS provider fails to get the NoLocal
attribute for this topic subscriber due to some
internal error.Apache Camel