org.apache.activemq.camel
Class CamelTopicSubscriber

java.lang.Object
  extended by org.apache.activemq.camel.CamelMessageConsumer
      extended by 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


Constructor Summary
CamelTopicSubscriber(CamelTopic destination, org.apache.camel.Endpoint endpoint, ActiveMQSession session, String name, String messageSelector, boolean noLocal)
           
 
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
 
Methods inherited from interface javax.jms.MessageConsumer
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
 

Constructor Detail

CamelTopicSubscriber

public CamelTopicSubscriber(CamelTopic destination,
                            org.apache.camel.Endpoint endpoint,
                            ActiveMQSession session,
                            String name,
                            String messageSelector,
                            boolean noLocal)
Method Detail

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–2013 The Apache Software Foundation. All rights reserved.