org.activemq
Class ActiveMQXAConnection
java.lang.Object
org.activemq.ActiveMQConnection
org.activemq.ActiveMQXAConnection
- All Implemented Interfaces:
- Connection, ExceptionListener, QueueConnection, TopicConnection, XAConnection, XAQueueConnection, XATopicConnection, CapacityMonitorEventListener, Closeable, StatsCapable, PacketListener, TransportStatusEventListener
public class ActiveMQXAConnection
- extends ActiveMQConnection
- implements XATopicConnection, XAQueueConnection, 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 $
- See Also:
Connection
,
ConnectionFactory
,
QueueConnection
,
TopicConnection
,
TopicConnectionFactory
,
QueueConnection
,
QueueConnectionFactory
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,
String theUserName,
String thePassword,
TransportChannel transportChannel)
throws JMSException
- Throws:
JMSException
ActiveMQXAConnection
public ActiveMQXAConnection(ActiveMQConnectionFactory factory,
String theUserName,
String thePassword)
throws JMSException
- Throws:
JMSException
createXASession
public XASession createXASession()
throws JMSException
- Specified by:
createXASession
in interface XAConnection
- Throws:
JMSException
createXATopicSession
public XATopicSession createXATopicSession()
throws JMSException
- Specified by:
createXATopicSession
in interface XATopicConnection
- Throws:
JMSException
createXAQueueSession
public XAQueueSession createXAQueueSession()
throws JMSException
- Specified by:
createXAQueueSession
in interface XAQueueConnection
- Throws:
JMSException
createSession
public Session createSession(boolean transacted,
int acknowledgeMode)
throws JMSException
- Description copied from class:
ActiveMQConnection
- Creates a
Session
object.
- Specified by:
createSession
in interface Connection
- Specified by:
createSession
in interface XAConnection
- Overrides:
createSession
in class ActiveMQConnection
- Parameters:
transacted
- indicates whether the session is transactedacknowledgeMode
- 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
.
- Returns:
- a newly created session
- Throws:
JMSException
- if the Connection
object fails to create a
session due to some internal error or lack of support for the
specific transaction and acknowledgement mode.- See Also:
Session.AUTO_ACKNOWLEDGE
,
Session.CLIENT_ACKNOWLEDGE
,
Session.DUPS_OK_ACKNOWLEDGE
Copyright © 2004-2010 Protique, Ltd.. All Rights Reserved.