public class XATopicConnection extends TopicConnection implements javax.jms.XATopicConnection
javax.jms.XATopicConnection
interface.Connection.AtomicCounter, Connection.Closer
Modifier and Type | Field and Description |
---|---|
private XAResourceMngr |
rm
Resource manager instance.
|
JMXBeanBaseName, logger, messageConsumers
Constructor and Description |
---|
XATopicConnection()
Creates an
XATopicConnection instance. |
Modifier and Type | Method and Description |
---|---|
javax.jms.Session |
createSession(boolean transacted,
int acknowledgeMode)
Method inherited from interface
XAConnection . |
javax.jms.TopicSession |
createTopicSession(boolean transacted,
int acknowledgeMode)
API method.
|
javax.jms.XASession |
createXASession()
Method inherited from interface
XAConnection . |
javax.jms.XATopicSession |
createXATopicSession()
API method.
|
XAResourceMngr |
getXAResourceMngr()
return XAResourceMngr of this connection.
|
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, 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 javax.jms.TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createTopicSession
in interface javax.jms.TopicConnection
createTopicSession
in interface javax.jms.XATopicConnection
createTopicSession
in class TopicConnection
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.XATopicSession createXATopicSession() throws javax.jms.JMSException
createXATopicSession
in interface javax.jms.XATopicConnection
javax.jms.IllegalStateException
- If the connection is closed.javax.jms.JMSException
public javax.jms.Session createSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
XAConnection
.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.
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.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
XAConnection
.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.