org.activemq
Class ActiveMQXAConnection 
java.lang.Object
org.activemq.ActiveMQConnection
org.activemq.ActiveMQXAConnection
- All Implemented Interfaces:
- org.activemq.capacity.CapacityMonitorEventListener, Closeable, javax.jms.Connection, javax.jms.ExceptionListener, org.activemq.message.PacketListener, javax.jms.QueueConnection, org.activemq.management.StatsCapable, javax.jms.TopicConnection, org.activemq.transport.TransportStatusEventListener, javax.jms.XAConnection, javax.jms.XAQueueConnection, javax.jms.XATopicConnection
- public class ActiveMQXAConnection
- extends ActiveMQConnection
- implements javax.jms.XATopicConnection, javax.jms.XAQueueConnection, javax.jms.XAConnection
The XAConnection interface extends the capability of Connection by providing
an XASession (optional).
The XAConnection interface is optional. JMS providers are not required to
support this interface. This interface is for use by JMS providers to
support transactional environments. Client programs are strongly encouraged
to use the transactional support available in their environment, rather
than use these XA interfaces directly.
- Version:
- $Revision: 1.1.1.1 $
| Methods inherited from class org.activemq.ActiveMQConnection |
addConnectionConsumer, addMessageDispatcher, addSession, addToTransientConsumedRedeliverCache, asyncSendPacket, asyncSendPacket, capacityChanged, changeUserInfo, checkClientIDWasManuallySpecified, checkClosed, cleanup, clearMessagesInProgress, close, closeTemporaryDestinations, consume, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createDurableConnectionConsumer, createQueueSession, createSession, createTopicSession, destroyDestination, doReconnect, generateSessionId, getAssemblies, getClientID, getConnectionMemoryLimit, getConnectionStats, getExceptionListener, getFragmentation, getInitializedClientID, getMemoryBoundedQueue, getMessageCompressionLevel, getMessageCompressionLimit, getMessageCompressionStrategy, getMessageFragmentationLimit, getMetaData, getNextConsumerNumber, getPrefetchPolicy, getResourceManagerId, getSendCloseTimeout, getSendConnectionInfoTimeout, getStats, getTransportChannel, handleAsyncException, isCachingEnabled, isCopyMessageOnSend, isDisableTimeStampsByDefault, isDoMessageCompression, isDoMessageFragmentation, isInternalConnection, isJ2EEcompliant, isOptimizedMessageDispatch, isPrepareMessageBodyOnSend, isQuickClose, isStarted, isUseAsyncSend, makeConnection, makeConnection, makeConnection, onException, removeConnectionConsumer, removeMessageDispatcher, removeSession, replayTransientConsumedRedeliveredMessages, sendConnectionInfoToBroker, sendConnectionInfoToBroker, setCachingEnabled, setClientID, setConnectionMemoryLimit, setCopyMessageOnSend, setDisableTimeStampsByDefault, setDoMessageCompression, setDoMessageFragmentation, setExceptionListener, setInternalConnection, setJ2EEcompliant, setMessageCompressionLevel, setMessageCompressionLimit, setMessageCompressionStrategy, setMessageFragmentationLimit, setOptimizedMessageDispatch, setPrefetchPolicy, setPrepareMessageBodyOnSend, setQuickClose, setSendCloseTimeout, setSendConnectionInfoTimeout, setUseAsyncSend, start, startAdvisoryForTempDestination, startTemporaryDestination, statusChanged, stop, stopAdvisoryForTempDestination, stopTemporaryDestination, syncSendPacket, syncSendPacket, syncSendRequest, terminateBrokerVM, validateDestination |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ActiveMQXAConnection
public ActiveMQXAConnection(ActiveMQConnectionFactory factory,
java.lang.String theUserName,
java.lang.String thePassword,
org.activemq.transport.TransportChannel transportChannel)
throws javax.jms.JMSException
ActiveMQXAConnection
public ActiveMQXAConnection(ActiveMQConnectionFactory factory,
java.lang.String theUserName,
java.lang.String thePassword)
throws javax.jms.JMSException
createXASession
public javax.jms.XASession createXASession()
throws javax.jms.JMSException
- Specified by:
createXASession in interface javax.jms.XAConnection
createXATopicSession
public javax.jms.XATopicSession createXATopicSession()
throws javax.jms.JMSException
- Specified by:
createXATopicSession in interface javax.jms.XATopicConnection
createXAQueueSession
public javax.jms.XAQueueSession createXAQueueSession()
throws javax.jms.JMSException
- Specified by:
createXAQueueSession in interface javax.jms.XAQueueConnection
createSession
public javax.jms.Session createSession(boolean transacted,
int acknowledgeMode)
throws javax.jms.JMSException
- Description copied from class:
ActiveMQConnection
- Creates a
Session object.
- Specified by:
createSession in interface javax.jms.XAConnection- Overrides:
createSession in class ActiveMQConnection
JAVADOC |