org.xmlBlaster.jms
Class XBTopicSubscriber

java.lang.Object
  org.xmlBlaster.jms.XBMessageConsumer
      org.xmlBlaster.jms.XBTopicSubscriber

All Implemented Interfaces:

javax.jms.MessageConsumer, javax.jms.TopicSubscriber, I_Callback

public class XBTopicSubscriber
extends XBMessageConsumer
implements javax.jms.TopicSubscriber

XBTopicSubscriber

Author:

Michele Laghi

Field Summary

private static java.lang.String

ME

Fields inherited from class org.xmlBlaster.jms.XBMessageConsumer

destination, exceptionListener, global, msg, msgListener, msgSelector, noLocal, open, session, subscribeReturnQos

Constructor Summary

XBTopicSubscriber(XBSession session, javax.jms.Destination destination, java.lang.String msgSelector, boolean noLocal)

Method Summary

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

Methods inherited from class org.xmlBlaster.jms.XBMessageConsumer

checkIfOpen, close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener, update

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

Field Detail

ME

private static final java.lang.String ME

See Also:

Constant Field Values

Constructor Detail

XBTopicSubscriber

XBTopicSubscriber(XBSession session,
                  javax.jms.Destination destination,
                  java.lang.String msgSelector,
                  boolean noLocal)
            throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

getNoLocal

public boolean getNoLocal()
                   throws javax.jms.JMSException

Specified by:

getNoLocal in interface javax.jms.TopicSubscriber

Throws:

javax.jms.JMSException

getTopic

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

Specified by:

getTopic in interface javax.jms.TopicSubscriber

Throws:

javax.jms.JMSException