com.latencybusters.jms
Class UMEMessageConsumer

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

All Implemented Interfaces:

javax.jms.MessageConsumer, javax.jms.TopicSubscriber

Direct Known Subclasses:

LBMTopicSubscriber

public class UMEMessageConsumer
extends LBMMessageConsumer
implements javax.jms.TopicSubscriber

Field Summary

Fields inherited from class com.latencybusters.jms.LBMMessageConsumer

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

Constructor Summary

UMEMessageConsumer()

UMEMessageConsumer(com.latencybusters.lbm.LBMContext myContext, com.latencybusters.lbm.LBMEventQueue evq, java.util.ArrayList<NameValue> props, LBMDestination dest, java.lang.String regid_offset, int acknowledgeMode, java.lang.String use_late_join, boolean isActive, LBMSession session, boolean transacted, java.lang.String cfName, java.lang.String messageSelector, java.lang.String durableSubscriptionName, boolean usingSessionIds, java.lang.String clientId)

Method Summary

void	close()
javax.jms.Destination	getDestination()
java.lang.String	getDurableSubscriptionName()
boolean	getNoLocal() This method has not been implemented.
javax.jms.Topic	getTopic()
protected void	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

getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener

Constructor Detail

UMEMessageConsumer

public UMEMessageConsumer()

UMEMessageConsumer

public UMEMessageConsumer(com.latencybusters.lbm.LBMContext myContext,
                          com.latencybusters.lbm.LBMEventQueue evq,
                          java.util.ArrayList<NameValue> props,
                          LBMDestination dest,
                          java.lang.String regid_offset,
                          int acknowledgeMode,
                          java.lang.String use_late_join,
                          boolean isActive,
                          LBMSession session,
                          boolean transacted,
                          java.lang.String cfName,
                          java.lang.String messageSelector,
                          java.lang.String durableSubscriptionName,
                          boolean usingSessionIds,
                          java.lang.String clientId)
                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

init

protected void init()
             throws javax.jms.JMSException

Overrides:

init in class LBMMessageConsumer

Throws:

javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface javax.jms.MessageConsumer

Overrides:

close in class LBMMessageConsumer

Throws:

javax.jms.JMSException

getNoLocal

public boolean getNoLocal()

This method has not been implemented.

Specified by:

getNoLocal in interface javax.jms.TopicSubscriber

getDestination

public javax.jms.Destination getDestination()

getTopic

public javax.jms.Topic getTopic()

Specified by:

getTopic in interface javax.jms.TopicSubscriber

getDurableSubscriptionName

public java.lang.String getDurableSubscriptionName()