org.jboss.mq
Class SpyTopicSubscriber

java.lang.Object
  org.jboss.mq.SpyMessageConsumer
      org.jboss.mq.SpyTopicSubscriber

All Implemented Interfaces:

Runnable, javax.jms.MessageConsumer, javax.jms.TopicSubscriber, SpyConsumer

public class SpyTopicSubscriber
extends SpyMessageConsumer
implements javax.jms.TopicSubscriber

This class implements javax.jms.TopicSubscriber.

Version:

$Revision: 1.11.6.2 $

Author:

Norbert Lataille (Norbert.Lataille@m4x.org), Hiram Chirino (Cojonudo14@hotmail.com), Adrian Brock

Field Summary

Fields inherited from class org.jboss.mq.SpyMessageConsumer

listenerThread, listening, receiving, session, stateLock, subscription, waitingForMessage

Method Summary

boolean	getNoLocal()
javax.jms.Topic	getTopic()

Methods inherited from class org.jboss.mq.SpyMessageConsumer

addMessage, close, getDestination, 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

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

Method Detail

getTopic

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

Specified by:

getTopic in interface javax.jms.TopicSubscriber

Throws:

javax.jms.JMSException

getNoLocal

public boolean getNoLocal()
                   throws javax.jms.JMSException

Specified by:

getNoLocal in interface javax.jms.TopicSubscriber

Overrides:

getNoLocal in class SpyMessageConsumer

Throws:

javax.jms.JMSException