org.xmlBlaster.jms
Class XBTopicSession

java.lang.Object
  java.lang.Thread
      org.xmlBlaster.jms.XBSession
          org.xmlBlaster.jms.XBTopicSession

All Implemented Interfaces:

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

public class XBTopicSession

extends XBSession

implements javax.jms.TopicSession

XBTopicSession

Author:

Michele Laghi

Field Summary

Fields inherited from class org.xmlBlaster.jms.XBSession

ackMode, channel, connection, connectionActivated, consumerMap, controlThread, durableDefault, durableSubscriptionMap, exceptionListener, global, MODE_ASYNC, MODE_SYNC, MODE_UNSET, msgListener, msgSelectorDefault, noLocalDefault, open, sessionName, syncMode, transacted, updateTimeout

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

(package private)

XBTopicSession(XBConnection connection, int ackMode, boolean transacted)

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 org.xmlBlaster.jms.XBSession

activateDispatcher, checkControlThread, checkIfOpen, checkIfTransacted, close, commit, connect, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamingMessage, createStreamMessage, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, getSyncMode, getTransacted, getUpdateTimeout, recover, rollback, run, setControlThread, setMessageListener, setStatusChangeListener, setSyncMode, unsubscribe, update

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, 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

XBTopicSession

XBTopicSession(XBConnection connection,
               int ackMode,
               boolean transacted)

Method Detail

createPublisher

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

Specified by:

createPublisher in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createSubscriber

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

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createSubscriber

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

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException