org.infinispan.transaction.xa.recovery
Class RecoveryAwareTransactionTable

java.lang.Object
  org.infinispan.transaction.TransactionTable
      org.infinispan.transaction.xa.XaTransactionTable
          org.infinispan.transaction.xa.recovery.RecoveryAwareTransactionTable

public class RecoveryAwareTransactionTable
extends XaTransactionTable

Transaction table that delegates prepared transaction's management to the RecoveryManager.

Since:

5.0

Author:

Mircea.Markus@jboss.com

Nested Class Summary

Nested classes/interfaces inherited from class org.infinispan.transaction.TransactionTable

TransactionTable.StaleTransactionCleanup

Field Summary

Fields inherited from class org.infinispan.transaction.xa.XaTransactionTable

xid2LocalTx

Fields inherited from class org.infinispan.transaction.TransactionTable

configuration, icc, localTransactions, remoteTransactions, txCoordinator, txFactory

Constructor Summary

RecoveryAwareTransactionTable()

Method Summary

void	failureCompletingTransaction(Transaction tx)
List<Xid>	getLocalPreparedXids()
Set<RecoveryAwareLocalTransaction>	getLocalTxThatFailedToComplete()
RemoteTransaction	getRemoteTransaction(GlobalTransaction txId) Returns the RemoteTransaction associated with the supplied transaction id.
Xid	getRemoteTransactionXid(Long internalId) Iterates over the remote transactions and returns the XID of the one that has an internal id equal with the supplied internal Id.
void	initialize(RecoveryManager recoveryManager)
void	localTransactionPrepared(LocalTransaction localTransaction)
void	remoteTransactionCompleted(GlobalTransaction gtx, boolean committed) Removes the RemoteTransaction corresponding to the given tx.
void	remoteTransactionPrepared(GlobalTransaction gtx)
void	removeCompletedRemoteTransactions(Xid id)
protected void	updateStateOnNodesLeaving(Collection<Address> leavers)

Methods inherited from class org.infinispan.transaction.xa.XaTransactionTable

addLocalTransactionMapping, enlist, getLocalTransaction, getLocalTxCount, getRecoveryManager, init, removeLocalTransaction, setRecoveryManager

Methods inherited from class org.infinispan.transaction.TransactionTable

containRemoteTx, containsLocalTx, createRemoteTransaction, createRemoteTransaction, getLocalTransaction, getLockedKeysForRemoteTransaction, getOrCreateLocalTransaction, getRemoteTransactions, getRemoteTxCount, initialize

Methods inherited from class java.lang.Object

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

Constructor Detail

RecoveryAwareTransactionTable

public RecoveryAwareTransactionTable()

Method Detail

initialize

public void initialize(RecoveryManager recoveryManager)

remoteTransactionPrepared

public void remoteTransactionPrepared(GlobalTransaction gtx)

Overrides:

remoteTransactionPrepared in class TransactionTable

localTransactionPrepared

public void localTransactionPrepared(LocalTransaction localTransaction)

Overrides:

localTransactionPrepared in class TransactionTable

updateStateOnNodesLeaving

protected void updateStateOnNodesLeaving(Collection<Address> leavers)

Overrides:

updateStateOnNodesLeaving in class TransactionTable

getRemoteTransaction

public RemoteTransaction getRemoteTransaction(GlobalTransaction txId)

Description copied from class: TransactionTable

Returns the RemoteTransaction associated with the supplied transaction id. Returns null if no such association exists.

Overrides:

getRemoteTransaction in class TransactionTable

remoteTransactionCompleted

public void remoteTransactionCompleted(GlobalTransaction gtx,
                                       boolean committed)

Description copied from class: TransactionTable

Removes the RemoteTransaction corresponding to the given tx.

Overrides:

remoteTransactionCompleted in class TransactionTable

getLocalPreparedXids

public List<Xid> getLocalPreparedXids()

removeCompletedRemoteTransactions

public void removeCompletedRemoteTransactions(Xid id)

failureCompletingTransaction

public void failureCompletingTransaction(Transaction tx)

Overrides:

failureCompletingTransaction in class TransactionTable

getLocalTxThatFailedToComplete

public Set<RecoveryAwareLocalTransaction> getLocalTxThatFailedToComplete()

getRemoteTransactionXid

public Xid getRemoteTransactionXid(Long internalId)

Iterates over the remote transactions and returns the XID of the one that has an internal id equal with the supplied internal Id.