org.fusesource.stompjms
Class StompJmsTopicSubscriber

java.lang.Object
  org.fusesource.stompjms.StompJmsMessageConsumer
      org.fusesource.stompjms.StompJmsTopicSubscriber

All Implemented Interfaces:

javax.jms.MessageConsumer, javax.jms.TopicSubscriber, StompJmsMessageListener

Direct Known Subclasses:

StompJmsDurableTopicSubscriber

public class StompJmsTopicSubscriber
extends StompJmsMessageConsumer
implements javax.jms.TopicSubscriber

Implementation of a TopicSubscriber

Method Summary

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

Methods inherited from class org.fusesource.stompjms.StompJmsMessageConsumer

checkClosed, close, getDestination, getId, getMessageListener, getMessageQueueSize, getMessageSelector, init, isBrowser, isDurableSubscription, onMessage, receive, receive, receiveNoWait, rollback, setMessageListener, start, stop

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

Method Detail

getNoLocal

public boolean getNoLocal()
                   throws javax.jms.IllegalStateException

Specified by:

getNoLocal in interface javax.jms.TopicSubscriber

Returns:

noLocak flag

Throws:

javax.jms.IllegalStateException

See Also:

TopicSubscriber.getNoLocal()

getTopic

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

Specified by:

getTopic in interface javax.jms.TopicSubscriber

Returns:

the Topic

Throws:

javax.jms.IllegalStateException

See Also:

TopicSubscriber.getTopic()