org.fusesource.stomp.jms

Class StompJmsTopicSubscriber

java.lang.Object

org.fusesource.stomp.jms.StompJmsMessageConsumer

org.fusesource.stomp.jms.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

Methods

Modifier and Type	Method and Description
boolean	getNoLocal()
javax.jms.Topic	getTopic()

Methods inherited from class org.fusesource.stomp.jms.StompJmsMessageConsumer

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

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

Overrides:

getNoLocal in class StompJmsMessageConsumer

Returns:

noLocal 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()