public class XAConnection extends Connection implements javax.jms.XAConnection
The XAConnection class extends the capability of Connection by providing an XASession. This class offers support to transactional environments. Client programs are strongly encouraged to use the transactional support available in their environment, rather than use these XA interfaces directly.
Connection.AtomicCounter, Connection.Closer
Modifier and Type | Field and Description |
---|---|
private XAResourceMngr |
rm
Resource manager instance.
|
JMXBeanBaseName, logger, messageConsumers
Constructor and Description |
---|
XAConnection()
Creates a
XAConnection instance. |
Modifier and Type | Method and Description |
---|---|
javax.jms.Session |
createSession(boolean transacted,
int acknowledgeMode)
Creates a non-XA session.
|
javax.jms.XASession |
createXASession()
Creates a XA session.
|
XAResourceMngr |
getXAResourceMngr()
return XAResourceMngr of this connection.
|
addSession, checkCLMessageProducer, checkClosed, checkCLSession, checkConsumers, checkThread, cleanup, close, closeConnectionConsumer, closeMessageConsumer, closeSession, createConnectionConsumer, createDurableConnectionConsumer, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, doClose, equals, getAsyncSend, getClientID, getCompressedMinSize, getCompressionLevel, getExceptionListener, getImplicitAck, getInInterceptors, getJMXBeanName, getMetaData, getOutInterceptors, getOutLocalAddress, getOutLocalPort, 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
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
close, createConnectionConsumer, createDurableConnectionConsumer, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
private XAResourceMngr rm
public javax.jms.Session createSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createSession
in interface javax.jms.Connection
createSession
in interface javax.jms.XAConnection
createSession
in class Connection
transacted
- indicates whether the session is transacted.acknowledgeMode
- indicates whether the consumer or the client will acknowledge any messages
it receives; ignored if the session is transacted. Legal values are
Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, and Session.DUPS_OK_ACKNOWLEDGE.javax.jms.IllegalStateException
- If the connection is closed.javax.jms.JMSException
- In case of an invalid acknowledge mode.public javax.jms.XASession createXASession() throws javax.jms.JMSException
createXASession
in interface javax.jms.XAConnection
javax.jms.IllegalStateException
- If the connection is closed.javax.jms.JMSException
public XAResourceMngr getXAResourceMngr()
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.