com.latencybusters.jms.topic
Class LBMTopicConnection

java.lang.Object
  com.latencybusters.jms.LBMConnection
      com.latencybusters.jms.topic.LBMTopicConnection

All Implemented Interfaces:

javax.jms.Connection, javax.jms.TopicConnection

public class LBMTopicConnection
extends LBMConnection
implements javax.jms.TopicConnection

Field Summary

Fields inherited from class com.latencybusters.jms.LBMConnection

allowClientIdChange, cfName, CLOSED, evq, INIT, myContext, OPEN, props, running, sessionList, STOPPED

Constructor Summary

LBMTopicConnection(com.latencybusters.lbm.LBMContext myContext, java.util.ArrayList<NameValue> props, boolean allowClientIdChange, java.lang.String clientID, com.latencybusters.lbm.LBMEventQueue evq, java.lang.String cfName, com.latencybusters.lbm.LBMContextAttributes qbContextAttributes)

Method Summary

javax.jms.TopicSession	createConnectionConsumer(javax.jms.Destination dest)
javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Topic topic, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) This method has not been implemented.
javax.jms.TopicSession	createTopicSession(boolean transacted, int acknowledgeMode)

Methods inherited from class com.latencybusters.jms.LBMConnection

addSource, close, closeSource, createConnectionConsumer, createDurableConnectionConsumer, createSession, dumpAttributeList, finalize, forwardException, getClientID, getDurableName, getDurables, getExceptionListener, getMetaData, getSource, logContextConfigOptions, setClientID, setExceptionListener, showNoOpException, start, stop

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.TopicConnection

createDurableConnectionConsumer

Methods inherited from interface javax.jms.Connection

close, createConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Constructor Detail

LBMTopicConnection

public LBMTopicConnection(com.latencybusters.lbm.LBMContext myContext,
                          java.util.ArrayList<NameValue> props,
                          boolean allowClientIdChange,
                          java.lang.String clientID,
                          com.latencybusters.lbm.LBMEventQueue evq,
                          java.lang.String cfName,
                          com.latencybusters.lbm.LBMContextAttributes qbContextAttributes)

Method Detail

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException

This method has not been implemented.

Specified by:

createConnectionConsumer in interface javax.jms.TopicConnection

Throws:

javax.jms.JMSException

createTopicSession

public javax.jms.TopicSession createTopicSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException

Specified by:

createTopicSession in interface javax.jms.TopicConnection

Throws:

javax.jms.JMSException

createConnectionConsumer

public javax.jms.TopicSession createConnectionConsumer(javax.jms.Destination dest)