Package org.apache.activemq.artemis.ra

Class ActiveMQRATopicSubscriber

java.lang.Object

org.apache.activemq.artemis.ra.ActiveMQRAMessageConsumer

org.apache.activemq.artemis.ra.ActiveMQRATopicSubscriber

All Implemented Interfaces:

MessageConsumer, TopicSubscriber, AutoCloseable

public class ActiveMQRATopicSubscriber
extends ActiveMQRAMessageConsumer
implements TopicSubscriber

A wrapper for a TopicSubscriber.

Field Summary

Fields inherited from class org.apache.activemq.artemis.ra.ActiveMQRAMessageConsumer

consumer, session

Constructor Summary

Constructors

Constructor	Description
ActiveMQRATopicSubscriber(TopicSubscriber consumer, ActiveMQRASession session)

Method Summary

Modifier and Type	Method	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.artemis.ra.ActiveMQRAMessageConsumer

close, getMessageListener, getMessageSelector, 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 jakarta.jms.MessageConsumer

close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener

Constructor Details

ActiveMQRATopicSubscriber

public ActiveMQRATopicSubscriber(TopicSubscriber consumer,
 ActiveMQRASession session)

Method Details

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 Jakarta Messaging provider fails to get the NoLocal attribute for this topic subscriber due to some internal error.

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 Jakarta Messaging provider fails to get the topic for this topic subscriber due to some internal error.