com.arjuna.ats.internal.jta.transaction.arjunacore.jca

Class TransactionImporterImple

java.lang.Object

com.arjuna.ats.internal.jta.transaction.arjunacore.jca.TransactionImporterImple

All Implemented Interfaces:

TransactionImporter

public class TransactionImporterImple
extends Object
implements TransactionImporter

Constructor Summary

Constructors

Constructor and Description
TransactionImporterImple()

Method Summary

Modifier and Type	Method and Description
SubordinateTransaction	getImportedTransaction(Xid xid) Get the subordinate (imported) transaction associated with the global transaction.
Set<Xid>	getInflightXids(String parentNodeName)
SubordinateTransaction	importTransaction(Xid xid) Create a subordinate transaction associated with the global transaction inflow.
SubordinateTransaction	importTransaction(Xid xid, int timeout) Create a subordinate transaction associated with the global transaction inflow and having a specified timeout.
TransactionImple	recoverTransaction(Uid actId) Used to recover an imported transaction.
void	removeImportedTransaction(Xid xid) Remove the subordinate (imported) transaction.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransactionImporterImple

public TransactionImporterImple()

Method Detail

importTransaction

public SubordinateTransaction importTransaction(Xid xid)
                                         throws XAException

Create a subordinate transaction associated with the global transaction inflow. No timeout is associated with the transaction.

Specified by:

importTransaction in interface TransactionImporter

Parameters:

xid - the global transaction.

Returns:

the subordinate transaction.

Throws:

XAException - thrown if there are any errors.

importTransaction

public SubordinateTransaction importTransaction(Xid xid,
                                                int timeout)
                                         throws XAException

Create a subordinate transaction associated with the global transaction inflow and having a specified timeout.

Specified by:

importTransaction in interface TransactionImporter

Parameters:

xid - the global transaction.

timeout - the timeout associated with the global transaction.

Returns:

the subordinate transaction.

Throws:

XAException - thrown if there are any errors.

recoverTransaction

public TransactionImple recoverTransaction(Uid actId)
                                    throws XAException

Used to recover an imported transaction.

Specified by:

recoverTransaction in interface TransactionImporter

Parameters:

actId - the state to recover.

Returns:

the recovered transaction object.

Throws:

XAException

getImportedTransaction

public SubordinateTransaction getImportedTransaction(Xid xid)
                                              throws XAException

Get the subordinate (imported) transaction associated with the global transaction.

Specified by:

getImportedTransaction in interface TransactionImporter

Parameters:

xid - the global transaction.

Returns:

the subordinate transaction or null if there is none.

Throws:

XAException - thrown if there are any errors.

removeImportedTransaction

public void removeImportedTransaction(Xid xid)
                               throws XAException

Remove the subordinate (imported) transaction.

Specified by:

removeImportedTransaction in interface TransactionImporter

Parameters:

xid - the global transaction.

Throws:

XAException - thrown if there are any errors.

getInflightXids

public Set<Xid> getInflightXids(String parentNodeName)