public class XAQueueConnection extends QueueConnection implements jakarta.jms.XAQueueConnection
jakarta.jms.XAQueueConnection
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 |
---|
XAQueueConnection()
Creates an
XAQueueConnection instance. |
Modifier and Type | Method and 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
|
createConnectionConsumer, createDurableConnectionConsumer, createQueueSession
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
close, createConnectionConsumer, createDurableConnectionConsumer, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
private XAResourceMngr rm
public XAQueueConnection()
XAQueueConnection
instance.public jakarta.jms.XAQueueSession createXAQueueSession() throws jakarta.jms.JMSException
createXAQueueSession
in interface jakarta.jms.XAQueueConnection
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.