Package org.ow2.joram.jakarta.jms

Class XAQueueConnection

java.lang.Object

org.ow2.joram.jakarta.jms.Connection

org.ow2.joram.jakarta.jms.QueueConnection

org.ow2.joram.jakarta.jms.XAQueueConnection

All Implemented Interfaces:

jakarta.jms.Connection, jakarta.jms.QueueConnection, jakarta.jms.XAConnection, jakarta.jms.XAQueueConnection, AutoCloseable, ConnectionMBean

public class XAQueueConnection
extends QueueConnection
implements jakarta.jms.XAQueueConnection

Implements the jakarta.jms.XAQueueConnection interface.

Nested Class Summary

Nested classes/interfaces inherited from class org.ow2.joram.jakarta.jms.Connection

Connection.AtomicCounter, Connection.Closer

Field Summary

Fields

Modifier and Type	Field	Description
private XAResourceMngr	rm	Resource manager instance.

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

JMXBeanBaseName, MESSAGE_ID_PREFIX_PROPERTY, messageConsumers

Constructor Summary

Constructors

Constructor	Description
XAQueueConnection()	Creates an XAQueueConnection instance.

Method Summary

Modifier and Type	Method	Description
jakarta.jms.XAQueueSession	createXAQueueSession()	API method.
jakarta.jms.XASession	createXASession()	Method inherited from interface XAConnection.
XAResourceMngr	getXAResourceMngr()	return XAResourceMngr of this connection. see connector

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

createConnectionConsumer, createDurableConnectionConsumer, createQueueSession

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

addSession, checkCLMessageProducer, checkClosed, checkCLSession, checkConsumers, checkThread, cleanup, close, closeConnectionConsumer, closeMessageConsumer, closeSession, createConnectionConsumer, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, doClose, equals, getAsyncSend, getClientID, getCompressedMinSize, getCompressionLevel, getExceptionListener, getImplicitAck, getInInterceptors, getJMXBeanName, getMetaData, getOutInterceptors, getOutLocalAddress, getOutLocalPort, getProxyId, getQueueMessageReadMax, getRequestMultiplexer, getTopicAckBufferMax, getTopicActivationThreshold, getTopicPassivationThreshold, getTxPendingTimer, hashCode, isOpenMessageConsumer, isStopped, lockClientId, nextMessageId, nextSessionId, nextSubName, open, openMessageConsumer, registerMBean, setClientID, setExceptionListener, setJMXBeanBaseName, setProviderClientID, start, stop, syncRequest, toString, unregisterMBean

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface jakarta.jms.Connection

close, createConnectionConsumer, createDurableConnectionConsumer, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Methods inherited from interface jakarta.jms.QueueConnection

createConnectionConsumer

Methods inherited from interface jakarta.jms.XAConnection

createSession

Methods inherited from interface jakarta.jms.XAQueueConnection

createQueueSession

Field Detail

rm

private XAResourceMngr rm

Resource manager instance.

Constructor Detail

XAQueueConnection

public XAQueueConnection()

Creates an XAQueueConnection instance.

Method Detail

createXAQueueSession

public jakarta.jms.XAQueueSession createXAQueueSession()
                                                throws jakarta.jms.JMSException

API method. Creates an XAQueueSession object.

Specified by:

createXAQueueSession in interface jakarta.jms.XAQueueConnection

Returns:

A newly created session.

Throws:

jakarta.jms.IllegalStateException - If the connection is closed.

jakarta.jms.JMSException

createXASession

public jakarta.jms.XASession createXASession()
                                      throws jakarta.jms.JMSException

Method inherited from interface XAConnection.

Specified by:

createXASession in interface jakarta.jms.XAConnection

Throws:

jakarta.jms.IllegalStateException - If the connection is closed.

jakarta.jms.JMSException

getXAResourceMngr

public XAResourceMngr getXAResourceMngr()

return XAResourceMngr of this connection. see connector