Package 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 Details

    • TransactionImporterImple

      public TransactionImporterImple()

  • Method Details

    • 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
      Description copied from interface: TransactionImporter
      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.

    • importRemoteTransaction

      public org.jboss.tm.TransactionImportResult importRemoteTransaction(Xid xid, int timeout) throws XAException
      Create a subordinate transaction associated with the global transaction inflow and having a specified timeout.
      Specified by:
      importRemoteTransaction 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)