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

Constructor Summary

Constructors

Constructor and Description
CamelTopicSubscriber(CamelTopic destination, org.apache.camel.Endpoint endpoint, ActiveMQSession session, String name, String messageSelector, boolean noLocal)

Method Summary

Methods

Modifier and Type	Method and Description
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.