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.QueueSession |
createQueueSession(boolean transacted,
int acknowledgeMode)
API method.
|
jakarta.jms.Session |
createSession(boolean transacted,
int acknowledgeMode)
Method inherited from interface
XAConnection . |
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
addSession, checkCLMessageProducer, checkClosed, checkCLSession, checkConsumers, checkThread, cleanup, close, closeConnectionConsumer, closeMessageConsumer, closeSession, createConnectionConsumer, 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.QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws jakarta.jms.JMSException
createQueueSession
in interface jakarta.jms.QueueConnection
createQueueSession
in interface jakarta.jms.XAQueueConnection
createQueueSession
in class QueueConnection
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.jakarta.jms.IllegalStateException
- If the connection is closed.jakarta.jms.JMSException
- In case of an invalid acknowledge mode.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.Session createSession(boolean transacted, int acknowledgeMode) throws jakarta.jms.JMSException
XAConnection
.createSession
in interface jakarta.jms.Connection
createSession
in interface jakarta.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.
Additionnaly Joram defines INDIVIDUAL_ACKNOWLEDGE: With this acknowledgment mode,
the client acknowledges a consumed message by calling the message's acknowledge
method. Contrary to CLIENT_ACKNOWLEDGE mode this mode allows to acknowledge only
the specified message.jakarta.jms.IllegalStateException
- If the connection is closed.jakarta.jms.JMSException
- In case of an invalid acknowledge mode.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 © 2022 ScalAgent D.T.. All rights reserved.