org.activemq.service.impl
Class TransactionManagerImpl

java.lang.Object
  extended by org.activemq.service.TransactionManager
      extended by org.activemq.service.impl.TransactionManagerImpl
All Implemented Interfaces:
Service
Direct Known Subclasses:
VMTransactionManager

public class TransactionManagerImpl
extends TransactionManager

Version:
$Revision: 1.1.1.1 $

Constructor Summary
TransactionManagerImpl(Broker broker, TransactionStore transactionStore)
           
 
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 getLocalTransaction(String txid)
           
 ActiveMQXid[] getPreparedXATransactions()
           
 Transaction getXATransaction(ActiveMQXid xid)
           
 void recover(Transaction transaction)
          Called on restart when recovering prepared transactions to reload a transaction from persistent store
 void start()
          Called to start the service
 void stop()
          Called to shutdown the service
 
Methods inherited from class org.activemq.service.TransactionManager
getContexTransaction, isCurrentTransaction, setContexTransaction
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TransactionManagerImpl

public TransactionManagerImpl(Broker broker,
                              TransactionStore transactionStore)
Method Detail

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
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-2010 Protique, Ltd.. All Rights Reserved.