public class RecoveryAwareTransactionTable extends XaTransactionTable
RecoveryManager
.TransactionTable.CompletedTransactionStatus
cacheName, recoveryManager, xid2LocalTx
CACHE_STOPPED_TOPOLOGY_ID, clustered, commandsFactory, configuration, partitionHandlingManager, rpcManager, running, transactionOriginatorChecker, txCoordinator
Constructor and Description |
---|
RecoveryAwareTransactionTable() |
Modifier and Type | Method and Description |
---|---|
void |
cleanupLeaverTransactions(List<Address> members)
First moves the prepared transactions originated on the leavers into the recovery cache and then cleans up the
transactions that are not yet prepared.
|
void |
failureCompletingTransaction(Transaction tx) |
List<XidImpl> |
getLocalPreparedXids() |
Set<RecoveryAwareLocalTransaction> |
getLocalTxThatFailedToComplete() |
RemoteTransaction |
getRemoteTransaction(GlobalTransaction txId)
Returns the
RemoteTransaction associated with the supplied transaction id. |
XidImpl |
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 |
localTransactionPrepared(LocalTransaction localTransaction) |
void |
remoteTransactionCommitted(GlobalTransaction gtx,
boolean onePc)
Removes the
RemoteTransaction corresponding to the given tx. |
void |
remoteTransactionPrepared(GlobalTransaction gtx)
Marks the transaction as prepared.
|
void |
remoteTransactionRollback(GlobalTransaction gtx) |
RemoteTransaction |
removeRemoteTransaction(XidImpl xid) |
commit, enlist, enlistClientTransaction, getLocalTransaction, getLocalTxCount, prepare, removeLocalTransaction, startXidMapping
afterCompletion, beforeCompletion, containRemoteTx, containsLocalTx, getCompletedTransactionStatus, getGlobalTransaction, getLocalGlobalTransaction, getLocalTransaction, getLocalTransaction, getLocalTransactions, getMinTopologyId, getOrCreateLocalTransaction, getOrCreateLocalTransaction, getOrCreateRemoteTransaction, getRemoteGlobalTransaction, getRemoteTransactions, getRemoteTxCount, isTransactionCompleted, markTransactionCompleted, onTopologyChange, onViewChange, recalculateMinTopologyIdIfNeeded, releaseLocksForCompletedTransaction, removeRemoteTransaction, start
public void remoteTransactionPrepared(GlobalTransaction gtx)
cleanupLeaverTransactions(java.util.List)
remoteTransactionPrepared
in class TransactionTable
public void localTransactionPrepared(LocalTransaction localTransaction)
localTransactionPrepared
in class TransactionTable
localTransactionPrepared(org.infinispan.transaction.impl.LocalTransaction)
public void cleanupLeaverTransactions(List<Address> members)
cleanupLeaverTransactions
in class TransactionTable
members
- The list of cluster memberspublic RemoteTransaction getRemoteTransaction(GlobalTransaction txId)
TransactionTable
RemoteTransaction
associated with the supplied transaction id. Returns null if no such
association exists.getRemoteTransaction
in class TransactionTable
public void remoteTransactionRollback(GlobalTransaction gtx)
remoteTransactionRollback
in class TransactionTable
public void remoteTransactionCommitted(GlobalTransaction gtx, boolean onePc)
TransactionTable
RemoteTransaction
corresponding to the given tx.remoteTransactionCommitted
in class TransactionTable
public void failureCompletingTransaction(Transaction tx)
failureCompletingTransaction
in class TransactionTable
public Set<RecoveryAwareLocalTransaction> getLocalTxThatFailedToComplete()
public XidImpl getRemoteTransactionXid(Long internalId)
public RemoteTransaction removeRemoteTransaction(XidImpl xid)
Copyright © 2021 JBoss by Red Hat. All rights reserved.