org.objectweb.jonas_jms
Class JQueueSession
java.lang.Object
org.objectweb.jonas_jms.JSession
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 interface javax.jms.Session |
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
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 |
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
- 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