org.xmlBlaster.jms
Class XBTopicSubscriber

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

All Implemented Interfaces:

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

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

(package private)

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

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