org.xmlBlaster.jms
Class XBQueueSession

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

All Implemented Interfaces:

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

public class XBQueueSession

extends XBSession

implements javax.jms.QueueSession

XBQueueSession

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)

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, 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.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)