org.jboss.mq
Class SpyTopicSubscriber

java.lang.Object
  extended byorg.jboss.mq.SpyMessageConsumer (src) 
      extended byorg.jboss.mq.SpyTopicSubscriber
All Implemented Interfaces:
MessageConsumer (src) , java.lang.Runnable, SpyConsumer (src) , TopicSubscriber (src)

public class SpyTopicSubscriber
extends SpyMessageConsumer (src)
implements TopicSubscriber (src)

This class implements javax.jms.TopicSubscriber.


Field Summary
 
Fields inherited from class org.jboss.mq.SpyMessageConsumer (src)
closed, listenerThread, listening, receiving, session, stateLock, subscription, waitingForMessage
 
Method Summary
 boolean getNoLocal()
          Gets the NoLocal attribute for this subscriber.
 Topic (src) getTopic()
          Gets the Topic associated with this subscriber.
 
Methods inherited from class org.jboss.mq.SpyMessageConsumer (src)
addMessage, close, getMessageListener, getMessageSelector, getSubscription, isListening, receive, receive, receiveNoWait, restartProcessing, run, sessionConsumerProcessMessage, setMessageListener, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface javax.jms.MessageConsumer (src)
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
 

Method Detail

getTopic

public Topic (src)  getTopic()
               throws JMSException (src) 
Description copied from interface: TopicSubscriber (src)
Gets the Topic associated with this subscriber.

Specified by:
getTopic in interface TopicSubscriber (src)
Returns:
this subscriber's Topic
Throws:
JMSException (src) - if the JMS provider fails to get the topic for this topic subscriber due to some internal error.

getNoLocal

public boolean getNoLocal()
                   throws JMSException (src) 
Description copied from interface: TopicSubscriber (src)
Gets the NoLocal attribute for this subscriber. The default value for this attribute is false.

Specified by:
getNoLocal in interface TopicSubscriber (src)
Returns:
true if locally published messages are being inhibited
Throws:
JMSException (src) - if the JMS provider fails to get the NoLocal attribute for this topic subscriber due to some internal error.