org.activemq.service.impl
Class TransactionManagerImpl
java.lang.Object
org.activemq.service.TransactionManager
org.activemq.service.impl.TransactionManagerImpl
- All Implemented Interfaces:
- Service
- Direct Known Subclasses:
- VMTransactionManager
- public class TransactionManagerImpl
- extends TransactionManager
- Version:
- $Revision: 1.1.1.1 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TransactionManagerImpl
public TransactionManagerImpl(Broker broker,
TransactionStore transactionStore)
createLocalTransaction
public Transaction createLocalTransaction(BrokerClient client,
String txid)
throws JMSException
- Specified by:
createLocalTransaction
in class TransactionManager
- Throws:
JMSException
- See Also:
TransactionManager.createLocalTransaction(org.activemq.broker.BrokerClient, String)
createXATransaction
public Transaction createXATransaction(BrokerClient client,
ActiveMQXid xid)
throws XAException
- Specified by:
createXATransaction
in class TransactionManager
- Throws:
XAException
- See Also:
TransactionManager.createXATransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid)
getLocalTransaction
public Transaction getLocalTransaction(String txid)
throws JMSException
- Specified by:
getLocalTransaction
in class TransactionManager
- Throws:
JMSException
- See Also:
TransactionManager.getLocalTransaction(String)
getXATransaction
public Transaction getXATransaction(ActiveMQXid xid)
throws XAException
- Specified by:
getXATransaction
in class TransactionManager
- Throws:
XAException
- See Also:
TransactionManager.getXATransaction(org.activemq.message.ActiveMQXid)
getPreparedXATransactions
public ActiveMQXid[] getPreparedXATransactions()
throws XAException
- Specified by:
getPreparedXATransactions
in class TransactionManager
- Throws:
XAException
- See Also:
TransactionManager.getPreparedXATransactions()
cleanUpClient
public void cleanUpClient(BrokerClient client)
throws JMSException
- Description copied from class:
TransactionManager
- A hint to the TransactionManager that an BrokerClient has stopped
This enables the TransactionManager to rollback in progess transactions
that the client created.
- Specified by:
cleanUpClient
in class TransactionManager
- Parameters:
client
-
- Throws:
JMSException
- See Also:
TransactionManager.cleanUpClient(org.activemq.broker.BrokerClient)
recover
public void recover(Transaction transaction)
- Description copied from class:
TransactionManager
- Called on restart when recovering prepared transactions to reload
a transaction from persistent store
- Specified by:
recover
in class TransactionManager
- See Also:
TransactionManager.recover(org.activemq.service.Transaction)
start
public void start()
throws JMSException
- Description copied from interface:
Service
- Called to start the service
- Throws:
JMSException
stop
public void stop()
throws JMSException
- Description copied from interface:
Service
- Called to shutdown the service
- Throws:
JMSException
Copyright © 2004-2007 Protique, Ltd.. All Rights Reserved.