org.apache.activemq.camel
Class CamelTopicSubscriber
java.lang.Object
org.apache.activemq.camel.CamelMessageConsumer
org.apache.activemq.camel.CamelTopicSubscriber
- All Implemented Interfaces:
- MessageConsumer, TopicSubscriber
public class CamelTopicSubscriber
- extends CamelMessageConsumer
- implements TopicSubscriber
A JMS TopicSubscriber
which consumes message exchanges from a
Camel Endpoint
- Version:
- $Revision: $
Method Summary |
boolean |
getNoLocal()
Gets the NoLocal attribute for this subscriber. |
Topic |
getTopic()
Gets the Topic associated with this subscriber. |
Methods inherited from class org.apache.activemq.camel.CamelMessageConsumer |
checkClosed, close, createConsumer, createMessage, getDestination, getEndpoint, getMessageListener, getMessageSelector, getPollingConsumer, getSession, isNoLocal, receive, receive, receiveNoWait, setMessageListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CamelTopicSubscriber
public CamelTopicSubscriber(CamelTopic destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session,
String name,
String messageSelector,
boolean noLocal)
getTopic
public Topic getTopic()
throws JMSException
- Gets the
Topic
associated with this subscriber.
- Specified by:
getTopic
in interface TopicSubscriber
- Returns:
- this subscriber's
Topic
- Throws:
JMSException
- if the JMS provider fails to get the topic for this topic
subscriber due to some internal error.
getNoLocal
public boolean getNoLocal()
throws JMSException
- Gets the
NoLocal
attribute for this subscriber. The
default value for this attribute is false.
- Specified by:
getNoLocal
in interface TopicSubscriber
- Returns:
- true if locally published messages are being inhibited
- Throws:
JMSException
- if the JMS provider fails to get the NoLocal
attribute for this topic subscriber due to some
internal error.
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.