org.objectweb.jonas_jms
Class JQueueSession

java.lang.Object
  extended by org.objectweb.jonas_jms.JSession
      extended by org.objectweb.jonas_jms.JQueueSession
All Implemented Interfaces:
java.lang.Runnable, javax.jms.QueueSession, javax.jms.Session, javax.transaction.Synchronization

public class JQueueSession
extends JSession
implements javax.jms.QueueSession

Author:
Laurent Chauvirey, Frederic Maistre, Nicolas Tachker Contributor(s): Philippe Durieux Philippe Coq

Field Summary
protected  javax.jms.QueueSession qs
           
protected  javax.jms.XAQueueConnection xaqc
           
protected  javax.jms.XAQueueSession xaqs
           
 
Fields inherited from class org.objectweb.jonas_jms.JSession
closed, currtx, jconn, sess, tm, txover, xac, xares, xasess
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Constructor Summary
JQueueSession(JConnection jconn, javax.jms.XAQueueConnection xaqc)
          Constructor
 
Method Summary
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
           
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, java.lang.String messageSelector)
           
 javax.jms.Queue createQueue(java.lang.String queueName)
           
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
           
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, java.lang.String messageSelector)
           
 javax.jms.QueueSender createSender(javax.jms.Queue queue)
           
 javax.jms.TemporaryQueue createTemporaryQueue()
           
protected  javax.jms.QueueSession getMOMQueueSession()
           
protected  javax.jms.Session getMOMSession()
          Get the underlaying MOM Session.
protected  void MOMSessionClose()
           
 
Methods inherited from class org.objectweb.jonas_jms.JSession
afterCompletion, beforeCompletion, close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, getTransacted, getXAResource, PhysicalClose, recover, rollback, run, setMessageListener, 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.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
 

Field Detail

xaqc

protected javax.jms.XAQueueConnection xaqc

qs

protected javax.jms.QueueSession qs

xaqs

protected javax.jms.XAQueueSession xaqs
Constructor Detail

JQueueSession

public JQueueSession(JConnection jconn,
                     javax.jms.XAQueueConnection xaqc)
Constructor

Method Detail

getMOMSession

protected javax.jms.Session getMOMSession()
                                   throws javax.jms.JMSException
Get the underlaying MOM Session.

Overrides:
getMOMSession in class JSession
Returns:
- session
Throws:
javax.jms.JMSException

getMOMQueueSession

protected javax.jms.QueueSession getMOMQueueSession()
                                             throws javax.jms.JMSException
Throws:
javax.jms.JMSException

MOMSessionClose

protected void MOMSessionClose()
Overrides:
MOMSessionClose in class JSession

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
                                     throws javax.jms.JMSException
Specified by:
createBrowser in interface javax.jms.QueueSession
Specified by:
createBrowser in interface javax.jms.Session
Overrides:
createBrowser in class JSession
Throws:
javax.jms.JMSException

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                            java.lang.String messageSelector)
                                     throws javax.jms.JMSException
Specified by:
createBrowser in interface javax.jms.QueueSession
Specified by:
createBrowser in interface javax.jms.Session
Overrides:
createBrowser in class JSession
Throws:
javax.jms.JMSException

createQueue

public javax.jms.Queue createQueue(java.lang.String queueName)
                            throws javax.jms.JMSException
Specified by:
createQueue in interface javax.jms.QueueSession
Specified by:
createQueue in interface javax.jms.Session
Overrides:
createQueue in class JSession
Throws:
javax.jms.JMSException

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

createReceiver

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

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

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException
Specified by:
createTemporaryQueue in interface javax.jms.QueueSession
Specified by:
createTemporaryQueue in interface javax.jms.Session
Overrides:
createTemporaryQueue in class JSession
Throws:
javax.jms.JMSException