org.objectweb.jonas_jms
Class JQueueSession

java.lang.Object
  |
  +--org.objectweb.jonas_jms.JSession
        |
        +--org.objectweb.jonas_jms.JQueueSession
All Implemented Interfaces:
javax.jms.QueueSession, java.lang.Runnable, javax.jms.Session, javax.transaction.xa.XAResource

public class JQueueSession
extends JSession
implements javax.jms.QueueSession


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, tm, txover, xares
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE
 
Fields inherited from interface javax.transaction.xa.XAResource
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
 
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
close, commit, commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, end, forget, getMessageListener, getTransacted, getTransactionTimeout, isSameRM, PhysicalClose, prepare, recover, recover, rollback, rollback, run, setMessageListener, setTransactionTimeout, start
 
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, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getMessageListener, getTransacted, recover, rollback, run, setMessageListener
 

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

getMOMQueueSession

protected javax.jms.QueueSession getMOMQueueSession()
                                             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

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

createQueue

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

createReceiver

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

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

createSender

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

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException
Specified by:
createTemporaryQueue in interface javax.jms.QueueSession