org.hornetq.ra

Class HornetQRATopicSubscriber

java.lang.Object

org.hornetq.ra.HornetQRAMessageConsumer

org.hornetq.ra.HornetQRATopicSubscriber

All Implemented Interfaces:

AutoCloseable, javax.jms.MessageConsumer, javax.jms.TopicSubscriber

public class HornetQRATopicSubscriber
extends HornetQRAMessageConsumer
implements javax.jms.TopicSubscriber

A wrapper for a topic subscriber

Author:

Adrian Brock, Jesper Pedersen

Field Summary

Fields inherited from class org.hornetq.ra.HornetQRAMessageConsumer

consumer, session

Constructor Summary

Constructors

Constructor and Description
HornetQRATopicSubscriber(javax.jms.TopicSubscriber consumer, HornetQRASession session) Create a new wrapper

Method Summary

Methods

Modifier and Type	Method and Description
boolean	getNoLocal() Get the no local value
javax.jms.Topic	getTopic() Get the topic

Methods inherited from class org.hornetq.ra.HornetQRAMessageConsumer

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 javax.jms.MessageConsumer

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

Constructor Detail

HornetQRATopicSubscriber

public HornetQRATopicSubscriber(javax.jms.TopicSubscriber consumer,
                        HornetQRASession session)

Create a new wrapper

Parameters:

consumer - the topic subscriber

session - the session

Method Detail

getNoLocal

public boolean getNoLocal()
                   throws javax.jms.JMSException

Get the no local value

Specified by:

getNoLocal in interface javax.jms.TopicSubscriber

Returns:

The value

Throws:

javax.jms.JMSException - Thrown if an error occurs

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException

Get the topic

Specified by:

getTopic in interface javax.jms.TopicSubscriber

Returns:

The topic

Throws:

javax.jms.JMSException - Thrown if an error occurs