public class XATopicConnection extends TopicConnection implements jakarta.jms.XATopicConnection
jakarta.jms.XATopicConnection
interface.Connection.AtomicCounter, Connection.Closer
Modifier and Type | Field and Description |
---|---|
private XAResourceMngr |
rm
Resource manager instance.
|
JMXBeanBaseName, logger, MESSAGE_ID_PREFIX_PROPERTY, messageConsumers, tracker
Constructor and Description |
---|
XATopicConnection()
Creates an
XATopicConnection instance. |
Modifier and Type | Method and Description |
---|---|
jakarta.jms.XASession |
createXASession()
Method inherited from interface
XAConnection . |
jakarta.jms.XATopicSession |
createXATopicSession()
API method.
|
XAResourceMngr |
getXAResourceMngr()
return XAResourceMngr of this connection.
|
createConnectionConsumer, createDurableConnectionConsumer, createTopicSession
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
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
private XAResourceMngr rm
public XATopicConnection()
XATopicConnection
instance.public jakarta.jms.XATopicSession createXATopicSession() throws jakarta.jms.JMSException
createXATopicSession
in interface jakarta.jms.XATopicConnection
jakarta.jms.IllegalStateException
- If the connection is closed.jakarta.jms.JMSException
public jakarta.jms.XASession createXASession() throws jakarta.jms.JMSException
XAConnection
.createXASession
in interface jakarta.jms.XAConnection
jakarta.jms.IllegalStateException
- If the connection is closed.jakarta.jms.JMSException
public XAResourceMngr getXAResourceMngr()
Copyright © 2023 ScalAgent D.T.. All rights reserved.