com.latencybusters.jms.topic
Class LBMTopicSession

java.lang.Object
  com.latencybusters.jms.LBMSession
      com.latencybusters.jms.topic.LBMTopicSession

All Implemented Interfaces:

java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession

public class LBMTopicSession
extends LBMSession
implements javax.jms.TopicSession

Field Summary

Fields inherited from class com.latencybusters.jms.LBMSession

acknowledgeMode, active, cfName, connection, consumerList, evq, listener, myContext, open, producerList, props, transacted, usingSessionIds

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

LBMTopicSession(LBMConnection connection, com.latencybusters.lbm.LBMContext myContext, com.latencybusters.lbm.LBMEventQueue evq, java.util.ArrayList<NameValue> props, int acknowledgeMode, boolean transacted, java.lang.String cfName)
This is an internal Method.

Method Summary

javax.jms.TopicPublisher	createPublisher(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic, java.lang.String messageSelector, boolean noLocal)

Methods inherited from class com.latencybusters.jms.LBMSession

close, commit, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, dispatch, flush, getAcknowledgeMode, getConnection, getMessageListener, getTransacted, isQueueEmpty, isSerializerAlive, recover, removeDurable, rollback, run, setMessageListener, start, startSerializer, stop, unsubscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.TopicSession

createDurableSubscriber, createDurableSubscriber, createTemporaryTopic, createTopic, unsubscribe

Methods inherited from interface javax.jms.Session

close, commit, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener

Constructor Detail

LBMTopicSession

public LBMTopicSession(LBMConnection connection,
                       com.latencybusters.lbm.LBMContext myContext,
                       com.latencybusters.lbm.LBMEventQueue evq,
                       java.util.ArrayList<NameValue> props,
                       int acknowledgeMode,
                       boolean transacted,
                       java.lang.String cfName)

This is an internal Method.

Method Detail

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.IllegalStateException,
                                                javax.jms.JMSException

Specified by:

createPublisher in interface javax.jms.TopicSession

Throws:

javax.jms.IllegalStateException

javax.jms.JMSException

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.IllegalStateException,
                                                  javax.jms.JMSException

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.IllegalStateException

javax.jms.JMSException

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
                                                  java.lang.String messageSelector,
                                                  boolean noLocal)
                                           throws javax.jms.IllegalStateException,
                                                  javax.jms.JMSException

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.IllegalStateException

javax.jms.JMSException