Class ActiveMQXAConnection

java.lang.Object

org.apache.activemq.artemis.jms.client.ActiveMQConnectionForContextImpl

org.apache.activemq.artemis.jms.client.ActiveMQConnection

org.apache.activemq.artemis.jms.client.ActiveMQXAConnection

All Implemented Interfaces:

jakarta.jms.Connection, jakarta.jms.QueueConnection, jakarta.jms.TopicConnection, jakarta.jms.XAConnection, jakarta.jms.XAQueueConnection, jakarta.jms.XATopicConnection, AutoCloseable, ActiveMQConnectionForContext

public final class ActiveMQXAConnection
extends ActiveMQConnection
implements jakarta.jms.XATopicConnection, jakarta.jms.XAQueueConnection

Apache Artemis implementation of a JMS XAConnection.

The flat implementation of XATopicConnection and XAQueueConnection is per design, following common practices of JMS 1.1.

Field Summary

Fields inherited from class ActiveMQConnection

CONNECTION_ID_PROPERTY_NAME, EXCEPTION_DISCONNECT, EXCEPTION_FAILOVER, TYPE_GENERIC_CONNECTION, TYPE_QUEUE_CONNECTION, TYPE_TOPIC_CONNECTION

Fields inherited from class ActiveMQConnectionForContextImpl

threadAwareContext

Constructor Summary

Constructors

Constructor	Description
ActiveMQXAConnection(ConnectionFactoryOptions options, String username, String password, int connectionType, String clientID, int dupsOKBatchSize, int transactionBatchSize, boolean cacheDestinations, boolean enable1xNaming, org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory)

Method Summary

Modifier and Type	Method	Description
jakarta.jms.XAQueueSession	createXAQueueSession()
jakarta.jms.XASession	createXASession()
jakarta.jms.XATopicSession	createXATopicSession()
protected boolean	isXA()

Methods inherited from class ActiveMQConnection

addTemporaryQueue, authorize, authorize, checkAck, checkClosed, close, containsTemporaryQueue, createAMQSession, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createNonXAQueueSession, createNonXASession, createNonXATopicSession, createQueueSession, createSession, createSession, createSession, createSessionInternal, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, createTopicSession, getClientID, getDeserializationAllowList, getDeserializationBlackList, getDeserializationDenyList, getDeserializationWhiteList, getExceptionListener, getFailoverListener, getInitialSession, getMetaData, getSessionFactory, getUID, hasNoLocal, isStarted, removeSession, removeTemporaryQueue, setClientID, setExceptionListener, setFailoverListener, setHasNoLocal, setReference, signalStopToAllSessions, start, stop

Methods inherited from class ActiveMQConnectionForContextImpl

closeFromContext, createContext, createXAContext, getThreadAwareContext, incrementRefCounter

Methods inherited from class Object

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

Methods inherited from interface jakarta.jms.Connection

close, createConnectionConsumer, 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.TopicConnection

createConnectionConsumer, createDurableConnectionConsumer

Methods inherited from interface jakarta.jms.XAConnection

createSession

Methods inherited from interface jakarta.jms.XAQueueConnection

createQueueSession

Methods inherited from interface jakarta.jms.XATopicConnection

createTopicSession

Constructor Details

ActiveMQXAConnection

public ActiveMQXAConnection(ConnectionFactoryOptions options,
 String username,
 String password,
 int connectionType,
 String clientID,
 int dupsOKBatchSize,
 int transactionBatchSize,
 boolean cacheDestinations,
 boolean enable1xNaming,
 org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory)

Method Details

createXASession

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

Specified by:

createXASession in interface jakarta.jms.XAConnection

Throws:

jakarta.jms.JMSException

createXAQueueSession

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

Specified by:

createXAQueueSession in interface jakarta.jms.XAQueueConnection

Throws:

jakarta.jms.JMSException

createXATopicSession

public jakarta.jms.XATopicSession createXATopicSession()
                                                throws jakarta.jms.JMSException

Specified by:

createXATopicSession in interface jakarta.jms.XATopicConnection

Throws:

jakarta.jms.JMSException

isXA

protected boolean isXA()

Overrides:

isXA in class ActiveMQConnection