org.codehaus.activemq.ra
Class ActiveMQRAConnection

java.lang.Object
  org.codehaus.activemq.ActiveMQConnection
      org.codehaus.activemq.ActiveMQXAConnection
          org.codehaus.activemq.ra.ActiveMQRAConnection

All Implemented Interfaces:

org.codehaus.activemq.capacity.CapacityMonitorEventListener, org.codehaus.activemq.Closeable, Connection, ExceptionListener, org.codehaus.activemq.message.PacketListener, QueueConnection, org.codehaus.activemq.management.StatsCapable, TopicConnection, org.codehaus.activemq.transport.TransportStatusEventListener, XAConnection, XAQueueConnection, XATopicConnection

public class ActiveMQRAConnection

extends org.codehaus.activemq.ActiveMQXAConnection

The ActiveMQRAConnection extends the ActiveMQXAConnection so that it is more flexible in terms of using the availble transaction context. A normal ActiveMQXAConnection implements the XAConnection interface stictly which means that it can only do work in the context of an XA transaction.

Version:

$Revision: 1.1.2.1 $

See Also:

Connection, ConnectionFactory, QueueConnection, TopicConnection, TopicConnectionFactory, QueueConnection, QueueConnectionFactory

Field Summary

Fields inherited from class org.codehaus.activemq.ActiveMQConnection

clientID, consumerIdGenerator, DEFAULT_PASSWORD, DEFAULT_URL, DEFAULT_USER, packetIdGenerator, useAsyncSend

Constructor Summary

ActiveMQRAConnection(org.codehaus.activemq.ActiveMQConnectionFactory factory, String theUserName, String thePassword)

ActiveMQRAConnection(org.codehaus.activemq.ActiveMQConnectionFactory factory, String theUserName, String thePassword, org.codehaus.activemq.transport.TransportChannel transportChannel)

Method Summary

protected org.codehaus.activemq.ActiveMQXASession

createActiveMQXASession(int acknowledgeMode)

Methods inherited from class org.codehaus.activemq.ActiveMQXAConnection

createQueueSession, createSession, createTopicSession, createXAQueueSession, createXASession, createXATopicSession, getResourceManagerId

Methods inherited from class org.codehaus.activemq.ActiveMQConnection

addConnectionConsumer, addMessageDispatcher, addSession, asyncSendPacket, asyncSendPacket, capacityChanged, checkClientIDWasManuallySpecified, checkClosed, clearMessagesInProgress, close, consume, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, destroyDestination, doReconnect, generateSessionId, getClientID, getConnectionMemoryLimit, getConnectionStats, getExceptionListener, getInitializedClientID, getMemoryBoundedQueue, getMetaData, getNextConsumerNumber, getPrefetchPolicy, getSendCloseTimeout, getSendConnectionInfoTimeout, getStats, getTransportChannel, handleAsyncException, isJ2EEcompliant, isStarted, isUseAsyncSend, makeConnection, makeConnection, makeConnection, onException, removeConnectionConsumer, removeMessageDispatcher, removeSession, sendConnectionInfoToBroker, sendConnectionInfoToBroker, setClientID, setConnectionMemoryLimit, setExceptionListener, setJ2EEcompliant, setPrefetchPolicy, setSendCloseTimeout, setSendConnectionInfoTimeout, setUseAsyncSend, start, statusChanged, stop, syncSendPacket, syncSendPacket, syncSendRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.Connection

close, createConnectionConsumer, createDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Methods inherited from interface javax.jms.TopicConnection

createConnectionConsumer, createDurableConnectionConsumer

Methods inherited from interface javax.jms.QueueConnection

createConnectionConsumer

Constructor Detail

ActiveMQRAConnection

public ActiveMQRAConnection(org.codehaus.activemq.ActiveMQConnectionFactory factory,
                            String theUserName,
                            String thePassword)
                     throws JMSException

ActiveMQRAConnection

public ActiveMQRAConnection(org.codehaus.activemq.ActiveMQConnectionFactory factory,
                            String theUserName,
                            String thePassword,
                            org.codehaus.activemq.transport.TransportChannel transportChannel)
                     throws JMSException

Method Detail

createActiveMQXASession

protected org.codehaus.activemq.ActiveMQXASession createActiveMQXASession(int acknowledgeMode)
                                                                   throws JMSException

Throws:

JMSException