|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.ActiveMQConnection
org.codehaus.activemq.ActiveMQXAConnection
org.codehaus.activemq.ra.ActiveMQRAConnection
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.
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 |
public ActiveMQRAConnection(org.codehaus.activemq.ActiveMQConnectionFactory factory, String theUserName, String thePassword) throws JMSException
public ActiveMQRAConnection(org.codehaus.activemq.ActiveMQConnectionFactory factory, String theUserName, String thePassword, org.codehaus.activemq.transport.TransportChannel transportChannel) throws JMSException
Method Detail |
protected org.codehaus.activemq.ActiveMQXASession createActiveMQXASession(int acknowledgeMode) throws JMSException
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |