org.apache.qpid.client
Class XAConnectionImpl

java.lang.Object
  extended by org.apache.qpid.client.Closeable
      extended by org.apache.qpid.client.AMQConnection
          extended by org.apache.qpid.client.XAConnectionImpl
All Implemented Interfaces:
Connection, QueueConnection, TopicConnection, XAConnection, XAQueueConnection, XATopicConnection, Referenceable

public class XAConnectionImpl
extends AMQConnection
implements XAConnection, XAQueueConnection, XATopicConnection

This class implements the javax.njms.XAConnection interface


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.client.AMQConnection
AMQConnection.ChannelToSessionMap
 
Field Summary
 
Fields inherited from class org.apache.qpid.client.AMQConnection
_connected, _delegate, _exceptionListener, _failoverPolicy, _maximumChannelCount, _protocolHandler, _started
 
Fields inherited from class org.apache.qpid.client.Closeable
_closed, _closing
 
Constructor Summary
XAConnectionImpl(ConnectionURL connectionURL, SSLConfiguration sslConfig)
          Create a XAConnection from a connectionURL
 
Method Summary
 XAQueueSession createXAQueueSession()
          Creates an XAQueueSession.
 XASession createXASession()
          Creates an XASession.
 XATopicSession createXATopicSession()
          Creates an XAQueueSession.
 
Methods inherited from class org.apache.qpid.client.AMQConnection
attemptReconnection, attemptReconnection, blockUntilNotFailingOver, bytesReceived, bytesSent, channelLimitReached, checkException, close, close, close, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createQueueSession, createSession, createSession, createSession, createTopicSession, deregisterSession, exceptionReceived, executeRetrySupport, failoverAllowed, failoverPrep, fireFailoverComplete, firePreFailover, firePreResubscribe, getActiveBrokerDetails, getClientID, getConnectionListener, getDefaultQueueExchangeName, getDefaultTopicExchangeName, getExceptionListener, getFailoverMutex, getFailoverPolicy, getMaximumChannelCount, getMaximumFrameSize, getMaxPrefetch, getMetaData, getNextChannelID, getPassword, getProtocolHandler, getProtocolVersion, getReference, getSession, getSessions, getSSLConfiguration, getSyncAck, getSyncPersistence, getSyncPublish, getTemporaryQueueExchangeName, getTemporaryTopicExchangeName, getUsername, getVirtualHost, isFailingOver, isUseLegacyMapMessageFormat, makeBrokerConnection, performConnectionTask, registerSession, resubscribeSessions, setClientID, setConnectionListener, setDefaultQueueExchangeName, setDefaultTopicExchangeName, setExceptionListener, setFailoverPolicy, setMaximumChannelCount, setMaximumFrameSize, setTemporaryQueueExchangeName, setTemporaryTopicExchangeName, setUsername, start, started, stop, toString, toURL
 
Methods inherited from class org.apache.qpid.client.Closeable
checkNotClosed, isClosed, isClosing
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface javax.jms.XAQueueConnection
createQueueSession
 
Methods inherited from interface javax.jms.QueueConnection
createConnectionConsumer
 
Methods inherited from interface javax.jms.XATopicConnection
createTopicSession
 
Methods inherited from interface javax.jms.XAConnection
createSession
 
Methods inherited from interface javax.jms.TopicConnection
createConnectionConsumer, createDurableConnectionConsumer
 
Methods inherited from interface javax.jms.Connection
close, createConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
 

Constructor Detail

XAConnectionImpl

public XAConnectionImpl(ConnectionURL connectionURL,
                        SSLConfiguration sslConfig)
                 throws org.apache.qpid.AMQException
Create a XAConnection from a connectionURL

Throws:
org.apache.qpid.AMQException
Method Detail

createXASession

public XASession createXASession()
                          throws JMSException
Creates an XASession.

Specified by:
createXASession in interface XAConnection
Returns:
A newly created XASession.
Throws:
JMSException - If the XAConnectiono fails to create an XASession due to some internal error.

createXAQueueSession

public XAQueueSession createXAQueueSession()
                                    throws JMSException
Creates an XAQueueSession.

Specified by:
createXAQueueSession in interface XAQueueConnection
Returns:
A newly created XASession.
Throws:
JMSException - If the XAQueueConnectionImpl fails to create an XASession due to some internal error.

createXATopicSession

public XATopicSession createXATopicSession()
                                    throws JMSException
Creates an XAQueueSession.

Specified by:
createXATopicSession in interface XATopicConnection
Returns:
A newly created XASession.
Throws:
JMSException - If the XAQueueConnectionImpl fails to create an XASession due to some internal error.


Licensed to the Apache Software Foundation