|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.service.impl.TransactionManagerImpl
Constructor Summary | |
TransactionManagerImpl(Broker broker,
PreparedTransactionStore preparedTransactions)
|
Method Summary | |
void |
cleanUpClient(BrokerClient client)
A hint to the TransactionManager that an BrokerClient has stopped This enables the TransactionManager to rollback in progess transactions that the client created. |
Transaction |
createLocalTransaction(BrokerClient client,
String txid)
|
Transaction |
createXATransaction(BrokerClient client,
ActiveMQXid xid)
|
Transaction |
getContexTransaction()
|
Transaction |
getLocalTransaction(String txid)
|
ActiveMQXid[] |
getPreparedXATransactions()
|
Transaction |
getXATransaction(ActiveMQXid xid)
|
void |
loadTransaction(ActiveMQXid xid,
Transaction transaction)
Called on restart when recovering prepared transactions to reload a transaction from persistent store |
void |
setContexTransaction(Transaction tx)
|
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public TransactionManagerImpl(Broker broker, PreparedTransactionStore preparedTransactions)
Method Detail |
public Transaction createLocalTransaction(BrokerClient client, String txid) throws JMSException
createLocalTransaction
in interface TransactionManager
JMSException
TransactionManager.createLocalTransaction(org.codehaus.activemq.broker.BrokerClient, String)
public Transaction createXATransaction(BrokerClient client, ActiveMQXid xid) throws XAException
createXATransaction
in interface TransactionManager
XAException
TransactionManager.createXATransaction(org.codehaus.activemq.broker.BrokerClient, org.codehaus.activemq.message.ActiveMQXid)
public Transaction getLocalTransaction(String txid) throws JMSException
getLocalTransaction
in interface TransactionManager
JMSException
TransactionManager.getLocalTransaction(String)
public Transaction getXATransaction(ActiveMQXid xid) throws XAException
getXATransaction
in interface TransactionManager
XAException
TransactionManager.getXATransaction(org.codehaus.activemq.message.ActiveMQXid)
public ActiveMQXid[] getPreparedXATransactions() throws XAException
getPreparedXATransactions
in interface TransactionManager
XAException
TransactionManager.getPreparedXATransactions()
public void setContexTransaction(Transaction tx)
setContexTransaction
in interface TransactionManager
TransactionManager.setContexTransaction(org.codehaus.activemq.service.Transaction)
public Transaction getContexTransaction()
getContexTransaction
in interface TransactionManager
TransactionManager.getContexTransaction()
public void cleanUpClient(BrokerClient client) throws JMSException
TransactionManager
cleanUpClient
in interface TransactionManager
client
-
JMSException
TransactionManager.cleanUpClient(org.codehaus.activemq.broker.BrokerClient)
public void loadTransaction(ActiveMQXid xid, Transaction transaction) throws XAException
TransactionManager
loadTransaction
in interface TransactionManager
xid
- transaction
-
XAException
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |