public class XaTransactionTable extends TransactionTable
TransactionTable to be used with TransactionXaAdapter.| Modifier and Type | Field and Description |
|---|---|
protected ConcurrentMap<Xid,LocalXaTransaction> |
xid2LocalTx |
CACHE_STOPPED_TOPOLOGY_ID, clustered, clusteringLogic, commandsFactory, configuration, icc, rpcManager, txCoordinator, txFactory| Constructor and Description |
|---|
XaTransactionTable() |
| Modifier and Type | Method and Description |
|---|---|
void |
addLocalTransactionMapping(LocalXaTransaction localTransaction) |
void |
enlist(Transaction transaction,
LocalTransaction ltx) |
LocalXaTransaction |
getLocalTransaction(Xid xid) |
int |
getLocalTxCount() |
RecoveryManager |
getRecoveryManager() |
void |
init(RecoveryManager recoveryManager,
Cache cache) |
boolean |
removeLocalTransaction(LocalTransaction localTx)
Removes the
TransactionXaAdapter corresponding to the given tx. |
void |
setRecoveryManager(RecoveryManager recoveryManager) |
cleanupStaleTransactions, containRemoteTx, containsLocalTx, failureCompletingTransaction, getLocalTransaction, getLocalTransaction, getLocalTransactions, getLockedKeysForRemoteTransaction, getMinTopologyId, getOrCreateLocalTransaction, getOrCreateRemoteTransaction, getRemoteTransaction, getRemoteTransactions, getRemoteTxCount, initialize, isTransactionCompleted, isTransactionCompletedSuccessfully, localTransactionPrepared, markTransactionCompleted, onTopologyChange, recalculateMinTopologyIdIfNeeded, remoteTransactionCommitted, remoteTransactionPrepared, remoteTransactionRollback, removeLocalTransactionInternal, removeRemoteTransactionprotected ConcurrentMap<Xid,LocalXaTransaction> xid2LocalTx
public void init(RecoveryManager recoveryManager, Cache cache)
public boolean removeLocalTransaction(LocalTransaction localTx)
TransactionTableTransactionXaAdapter corresponding to the given tx. Returns true
if such an tx exists.removeLocalTransaction in class TransactionTablepublic LocalXaTransaction getLocalTransaction(Xid xid)
public void addLocalTransactionMapping(LocalXaTransaction localTransaction)
public void enlist(Transaction transaction, LocalTransaction ltx)
enlist in class TransactionTablepublic RecoveryManager getRecoveryManager()
public void setRecoveryManager(RecoveryManager recoveryManager)
public int getLocalTxCount()
getLocalTxCount in class TransactionTableCopyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.