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

public class StompJmsTopicSubscriber
extends StompJmsMessageConsumer
implements javax.jms.TopicSubscriber

Implementation of a TopicSubscriber

Field Summary

Fields inherited from class org.fusesource.stompjms.StompJmsMessageConsumer

destination, session

Constructor Summary

protected

StompJmsTopicSubscriber(java.lang.String id, StompJmsSession s, StompJmsDestination destination, boolean noLocal, java.lang.String selector) Constructor

Method Summary

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

Methods inherited from class org.fusesource.stompjms.StompJmsMessageConsumer

checkClosed, close, getDestination, getId, getMessageListener, getMessageQueueSize, getMessageSelector, 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

Constructor Detail

StompJmsTopicSubscriber

protected StompJmsTopicSubscriber(java.lang.String id,
                                  StompJmsSession s,
                                  StompJmsDestination destination,
                                  boolean noLocal,
                                  java.lang.String selector)

Constructor

Parameters:

s -

destination -

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