public class XAConnectionImpl extends AMQConnection implements javax.jms.XAConnection, javax.jms.XAQueueConnection, javax.jms.XATopicConnection
JNDI_ADDRESS_CONNECTION_URL
Constructor and Description |
---|
XAConnectionImpl(ConnectionURL connectionURL)
Create a XAConnection from a connectionURL
|
Modifier and Type | Method and Description |
---|---|
javax.jms.XAQueueSession |
createXAQueueSession()
Creates an XAQueueSession.
|
javax.jms.XASession |
createXASession()
Creates an XASession.
|
javax.jms.XASession |
createXASession(int ackMode) |
javax.jms.XATopicSession |
createXATopicSession()
Creates an XAQueueSession.
|
attemptReconnection, attemptReconnection, blockUntilNotFailingOver, bytesReceived, bytesSent, channelLimitReached, close, close, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createQueueSession, createSession, createSession, createSession, createTopicSession, deregisterSession, exceptionReceived, executeRetrySupport, failoverAllowed, fireFailoverComplete, firePreFailover, firePreResubscribe, getActiveBrokerDetails, getBrokerSuppliedTrustStore, getBrokerUUID, getClientID, getConnectionListener, getConnectionNumber, getConnectionSettings, getConnectionURL, getDefaultQueueExchangeName, getDefaultTopicExchangeName, getDelegate, getExceptionListener, getExceptionListenerNoCheck, getFailoverMutex, getFailoverPolicy, getLastFailoverTime, getMaximumChannelCount, getMaximumFrameSize, getMaxPrefetch, getMessageCompressionThresholdSize, getMetaData, getNextChannelID, getPassword, getProtocolHandler, getProtocolVersion, getReference, getSession, getSessions, getSyncAck, getSyncPersistence, getSyncPublish, getTemporaryQueueExchangeName, getTemporaryQueuePrefix, getTemporaryTopicExchangeName, getUsername, getVirtualHost, isConnected, isFailingOver, isMessageCompressionDesired, isPopulateUserId, isTrusted, isUseLegacyMapMessageFormat, isUseLegacyStreamMessageFormat, logConnected, makeBrokerConnection, performConnectionTask, resubscribeSessions, setClientID, setConnected, setConnectionListener, setConnectionSettings, setDefaultQueueExchangeName, setDefaultTopicExchangeName, setExceptionListener, setFailoverPolicy, setMaximumChannelCount, setMaximumFrameSize, setTemporaryQueueExchangeName, setTemporaryTopicExchangeName, setUsername, start, started, stop, toString, toURL, validateQueueOnSend
checkNotClosed, isClosed, isClosing, setClosed, setClosing
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createConnectionConsumer, createDurableConnectionConsumer
close, createConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
isClosed
public XAConnectionImpl(ConnectionURL connectionURL) throws QpidException
QpidException
public javax.jms.XASession createXASession() throws javax.jms.JMSException
createXASession
in interface javax.jms.XAConnection
javax.jms.JMSException
- If the XAConnectiono fails to create an XASession due to
some internal error.public javax.jms.XAQueueSession createXAQueueSession() throws javax.jms.JMSException
createXAQueueSession
in interface javax.jms.XAQueueConnection
javax.jms.JMSException
- If the XAQueueConnectionImpl fails to create an XASession due to
some internal error.public javax.jms.XATopicSession createXATopicSession() throws javax.jms.JMSException
createXATopicSession
in interface javax.jms.XATopicConnection
javax.jms.JMSException
- If the XAQueueConnectionImpl fails to create an XASession due to
some internal error.public javax.jms.XASession createXASession(int ackMode) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.