org.apache.activemq.artemis.jms.client

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:

AutoCloseable, Connection, QueueConnection, TopicConnection, XAConnection, XAQueueConnection, XATopicConnection, ActiveMQConnectionForContext

public final class ActiveMQXAConnection
extends ActiveMQConnection
implements XATopicConnection, XAQueueConnection

ActiveMQ 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 org.apache.activemq.artemis.jms.client.ActiveMQConnection

CONNECTION_ID_PROPERTY_NAME, EXCEPTION_DISCONNECT, EXCEPTION_FAILOVER, JMS_SESSION_CLIENT_ID_PROPERTY, TYPE_GENERIC_CONNECTION, TYPE_QUEUE_CONNECTION, TYPE_TOPIC_CONNECTION

Fields inherited from class org.apache.activemq.artemis.jms.client.ActiveMQConnectionForContextImpl

threadAwareContext

Constructor Summary

Constructors

Constructor and Description
ActiveMQXAConnection(ConnectionFactoryOptions options, String username, String password, int connectionType, String clientID, int dupsOKBatchSize, int transactionBatchSize, boolean cacheDestinations, boolean enable1xNaming, ClientSessionFactory sessionFactory)

Method Summary

Modifier and Type	Method and Description
XAQueueSession	createXAQueueSession() Creates an XAQueueSession object.
XASession	createXASession() Creates an XASession object.
XATopicSession	createXATopicSession() Creates an XATopicSession object.
protected boolean	isXA()

Methods inherited from class org.apache.activemq.artemis.jms.client.ActiveMQConnection

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

Methods inherited from class org.apache.activemq.artemis.jms.client.ActiveMQConnectionForContextImpl

closeFromContext, createContext, createXAContext, getThreadAwareContext, incrementRefCounter

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.XATopicConnection

createTopicSession

Methods inherited from interface javax.jms.TopicConnection

createConnectionConsumer, createDurableConnectionConsumer

Methods inherited from interface javax.jms.XAQueueConnection

createQueueSession

Methods inherited from interface javax.jms.XAConnection

createSession

Methods inherited from interface javax.jms.QueueConnection

createConnectionConsumer

Methods inherited from interface javax.jms.Connection

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

Constructor Detail

ActiveMQXAConnection

public ActiveMQXAConnection(ConnectionFactoryOptions options,
                            String username,
                            String password,
                            int connectionType,
                            String clientID,
                            int dupsOKBatchSize,
                            int transactionBatchSize,
                            boolean cacheDestinations,
                            boolean enable1xNaming,
                            ClientSessionFactory sessionFactory)

Method Detail

createXASession

public XASession createXASession()
                          throws JMSException

Description copied from interface: XAConnection

Creates an XASession object.

Specified by:

createXASession in interface XAConnection

Returns:

a newly created XASession

Throws:

JMSException - if the XAConnection object fails to create an XASession due to some internal error.

createXAQueueSession

public XAQueueSession createXAQueueSession()
                                    throws JMSException

Description copied from interface: XAQueueConnection

Creates an XAQueueSession object.

Specified by:

createXAQueueSession in interface XAQueueConnection

Returns:

a newly created XAQueueSession

Throws:

JMSException - if the XAQueueConnection object fails to create an XAQueueSession due to some internal error.

createXATopicSession

public XATopicSession createXATopicSession()
                                    throws JMSException

Description copied from interface: XATopicConnection

Creates an XATopicSession object.

Specified by:

createXATopicSession in interface XATopicConnection

Returns:

a newly created XATopicSession

Throws:

JMSException - if the XATopicConnection object fails to create an XATopicSession due to some internal error.

isXA

protected boolean isXA()

Overrides:

isXA in class ActiveMQConnection