xmlBlaster 2.2.0 API

org.xmlBlaster.jms
Class XBQueueSession

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

public class XBQueueSession
extends XBSession
implements javax.jms.QueueSession

XBQueueSession

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
XBQueueSession(XBConnection connection, int ackMode, boolean transacted)
           
 
Method Summary
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
           
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, java.lang.String msgSelector)
           
 javax.jms.QueueSender createSender(javax.jms.Queue queue)
           
 
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.QueueSession
createBrowser, createBrowser, createQueue, createTemporaryQueue
 
Methods inherited from interface javax.jms.Session
close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener, unsubscribe
 

Constructor Detail

XBQueueSession

XBQueueSession(XBConnection connection,
               int ackMode,
               boolean transacted)
Method Detail

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
                                       throws javax.jms.JMSException
Specified by:
createReceiver in interface javax.jms.QueueSession
Throws:
javax.jms.JMSException
See Also:
QueueSession.createReceiver(javax.jms.Queue)

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue,
                                              java.lang.String msgSelector)
                                       throws javax.jms.JMSException
Specified by:
createReceiver in interface javax.jms.QueueSession
Throws:
javax.jms.JMSException
See Also:
QueueSession.createReceiver(javax.jms.Queue, java.lang.String)

createSender

public javax.jms.QueueSender createSender(javax.jms.Queue queue)
                                   throws javax.jms.JMSException
Specified by:
createSender in interface javax.jms.QueueSession
Throws:
javax.jms.JMSException
See Also:
QueueSession.createSender(javax.jms.Queue)

xmlBlaster 2.2.0 API

Copyright © 1999-2014 The xmlBlaster.org contributers.