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 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 |
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 |
xaqc
protected javax.jms.XAQueueConnection xaqc
qs
protected javax.jms.QueueSession qs
xaqs
protected javax.jms.XAQueueSession xaqs
JQueueSession
public JQueueSession(JConnection jconn,
javax.jms.XAQueueConnection xaqc)
- Constructor
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