xmlBlaster 2.2.0 API

org.xmlBlaster.jms
Class XBTopicSession

java.lang.Object
  extended by java.lang.Thread
      extended by org.xmlBlaster.jms.XBSession
          extended by org.xmlBlaster.jms.XBTopicSession
All Implemented Interfaces:
java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession, I_Callback

public class XBTopicSession
extends XBSession
implements javax.jms.TopicSession

XBTopicSession

Author:
Michele Laghi

Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
 
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
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, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, 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

xmlBlaster 2.2.0 API

Copyright © 1999-2014 The xmlBlaster.org contributers.