Package org.ow2.joram.jakarta.jms

Class XAQueueSession

java.lang.Object

org.ow2.joram.jakarta.jms.XASession

org.ow2.joram.jakarta.jms.XAQueueSession

All Implemented Interfaces:

jakarta.jms.Session, jakarta.jms.XAQueueSession, jakarta.jms.XASession, AutoCloseable, Runnable

public class XAQueueSession
extends XASession
implements jakarta.jms.XAQueueSession

Implements the jakarta.jms.XAQueueSession interface.

Field Summary

Fields inherited from class org.ow2.joram.jakarta.jms.XASession

sess

Fields inherited from interface jakarta.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

Constructors

Constructor	Description
XAQueueSession(XAQueueConnection cnx, QueueSession qs, XAResourceMngr rm)	Constructs an XAQueueSession instance.

Method Summary

Modifier and Type	Method	Description
jakarta.jms.QueueReceiver	createReceiver(Queue queue)	Delegates the call to the wrapped JMS session.
jakarta.jms.QueueReceiver	createReceiver(Queue queue, String selector)	Delegates the call to the wrapped JMS session.
jakarta.jms.QueueSender	createSender(Queue queue)	Delegates the call to the wrapped JMS session.
jakarta.jms.QueueSession	getQueueSession()	API method.
String	toString()	Returns a String image of this session.

Methods inherited from class org.ow2.joram.jakarta.jms.XASession

close, commit, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableConsumer, createDurableConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createSharedConsumer, createSharedConsumer, createSharedDurableConsumer, createSharedDurableConsumer, createStreamMessage, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getDelegateSession, getMessageListener, getSession, getTransacted, getXAResource, recover, rollback, run, setMessageListener, unsubscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface jakarta.jms.Session

close, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableConsumer, createDurableConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createSharedConsumer, createSharedConsumer, createSharedDurableConsumer, createSharedDurableConsumer, createStreamMessage, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, recover, run, setMessageListener, unsubscribe

Methods inherited from interface jakarta.jms.XASession

commit, getSession, getTransacted, getXAResource, rollback

Constructor Detail

XAQueueSession

XAQueueSession(XAQueueConnection cnx,
               QueueSession qs,
               XAResourceMngr rm)
        throws jakarta.jms.JMSException

Constructs an XAQueueSession instance.

Parameters:

cnx - The connection the session belongs to.

rm - The resource manager.

Throws:

jakarta.jms.JMSException - Actually never thrown.

Method Detail

toString

public String toString()

Returns a String image of this session.

Overrides:

toString in class XASession

getQueueSession

public jakarta.jms.QueueSession getQueueSession()
                                         throws jakarta.jms.JMSException

API method. Gets the queue session associated with this XAQueueSession.

Specified by:

getQueueSession in interface jakarta.jms.XAQueueSession

Returns:

the queue session object.

Throws:

jakarta.jms.JMSException - if an internal error occurs.

createSender

public jakarta.jms.QueueSender createSender(Queue queue)
                                     throws jakarta.jms.JMSException

Delegates the call to the wrapped JMS session.

Throws:

jakarta.jms.JMSException

createReceiver

public jakarta.jms.QueueReceiver createReceiver(Queue queue,
                                                String selector)
                                         throws jakarta.jms.JMSException

Delegates the call to the wrapped JMS session.

Throws:

jakarta.jms.JMSException

createReceiver

public jakarta.jms.QueueReceiver createReceiver(Queue queue)
                                         throws jakarta.jms.JMSException

Delegates the call to the wrapped JMS session.

Throws:

jakarta.jms.JMSException