com.latencybusters.jms.topic
Class LBMTopicSubscriber

java.lang.Object
  com.latencybusters.jms.LBMMessageConsumer
      com.latencybusters.jms.UMEMessageConsumer
          com.latencybusters.jms.topic.LBMTopicSubscriber

All Implemented Interfaces:

javax.jms.MessageConsumer, javax.jms.TopicSubscriber

public class LBMTopicSubscriber
extends UMEMessageConsumer
implements javax.jms.TopicSubscriber

Field Summary

Fields inherited from class com.latencybusters.jms.LBMMessageConsumer

acknowledgeMode, cfName, evq, listener, messageSelector, myContext, rcvCreationDelay, transacted

Constructor Summary

LBMTopicSubscriber(javax.jms.Topic topic, com.latencybusters.lbm.LBMContext myContext, com.latencybusters.lbm.LBMEventQueue evq, java.util.ArrayList<NameValue> props, boolean active, int acknowledgeMode, LBMSession session, boolean transacted, java.lang.String cfName, java.lang.String messageSelector, boolean usingSessionIds, java.lang.String clientId)
This is an internal Method.

Method Summary

boolean	getNoLocal() This method has not been implemented.
javax.jms.Topic	getTopic()

Methods inherited from class com.latencybusters.jms.UMEMessageConsumer

close, getDestination, getDurableSubscriptionName, init

Methods inherited from class com.latencybusters.jms.LBMMessageConsumer

acked, addTransaction, addUnAckedMessage, commit, dumpAttributeList, getDefaultMessageProp, getMessageListener, getMessageSelector, getName, getSession, isActive, isOpen, isTransacted, logReceiverConfigOptions, printAttr, receive, receive, receiveNoWait, removeCallback, rollback, setMessageListener, setTransacted, 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

LBMTopicSubscriber

public LBMTopicSubscriber(javax.jms.Topic topic,
                          com.latencybusters.lbm.LBMContext myContext,
                          com.latencybusters.lbm.LBMEventQueue evq,
                          java.util.ArrayList<NameValue> props,
                          boolean active,
                          int acknowledgeMode,
                          LBMSession session,
                          boolean transacted,
                          java.lang.String cfName,
                          java.lang.String messageSelector,
                          boolean usingSessionIds,
                          java.lang.String clientId)
                   throws javax.jms.JMSException

This is an internal Method.

Throws:

javax.jms.JMSException

Method Detail

getNoLocal

public boolean getNoLocal()

Description copied from class: UMEMessageConsumer

This method has not been implemented.

Specified by:

getNoLocal in interface javax.jms.TopicSubscriber

Overrides:

getNoLocal in class UMEMessageConsumer

getTopic

public javax.jms.Topic getTopic()

Specified by:

getTopic in interface javax.jms.TopicSubscriber

Overrides:

getTopic in class UMEMessageConsumer