com.latencybusters.jms.queue
Class LBMQueueConnection

java.lang.Object
  com.latencybusters.jms.LBMConnection
      com.latencybusters.jms.queue.LBMQueueConnection

All Implemented Interfaces:

javax.jms.Connection, javax.jms.QueueConnection

public class LBMQueueConnection
extends LBMConnection
implements javax.jms.QueueConnection

Field Summary

Fields inherited from class com.latencybusters.jms.LBMConnection

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

Constructor Summary

LBMQueueConnection(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.ConnectionConsumer	createConnectionConsumer(javax.jms.Queue queue, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) This method is not implemented.
javax.jms.QueueSession	createQueueSession(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.Connection

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

Constructor Detail

LBMQueueConnection

public LBMQueueConnection(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.Queue queue,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException

This method is not implemented.

Specified by:

createConnectionConsumer in interface javax.jms.QueueConnection

Throws:

javax.jms.JMSException

createQueueSession

public javax.jms.QueueSession createQueueSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException

Specified by:

createQueueSession in interface javax.jms.QueueConnection

Throws:

javax.jms.JMSException