org.codehaus.activemq.ra
Class ActiveMQRAConnection

java.lang.Object
  extended byorg.codehaus.activemq.ActiveMQConnection
      extended byorg.codehaus.activemq.ActiveMQXAConnection
          extended byorg.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


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.