Package org.infinispan.transaction.xa
Class XaTransactionTable
- java.lang.Object
-
- org.infinispan.transaction.impl.TransactionTable
-
- org.infinispan.transaction.xa.XaTransactionTable
-
- All Implemented Interfaces:
TransactionTable
- Direct Known Subclasses:
RecoveryAwareTransactionTable
public class XaTransactionTable extends TransactionTable
TransactionTable
to be used withTransactionXaAdapter
.- Since:
- 5.0
- Author:
- Mircea.Markus@jboss.com
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.infinispan.transaction.impl.TransactionTable
TransactionTable.CompletedTransactionStatus
-
-
Field Summary
Fields Modifier and Type Field Description protected String
cacheName
protected RecoveryManager
recoveryManager
protected ConcurrentMap<XidImpl,LocalXaTransaction>
xid2LocalTx
-
Fields inherited from class org.infinispan.transaction.impl.TransactionTable
CACHE_STOPPED_TOPOLOGY_ID, clustered, commandsFactory, configuration, partitionHandlingManager, rpcManager, running, transactionOriginatorChecker, txCoordinator
-
-
Constructor Summary
Constructors Constructor Description XaTransactionTable()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CompletionStage<Void>
commit(XidImpl xid, boolean isOnePhase)
void
enlist(javax.transaction.Transaction transaction, LocalTransaction ltx)
void
enlistClientTransaction(javax.transaction.Transaction transaction, LocalTransaction localTransaction)
LocalXaTransaction
getLocalTransaction(XidImpl xid)
int
getLocalTxCount()
CompletionStage<Integer>
prepare(XidImpl xid)
boolean
removeLocalTransaction(LocalTransaction localTx)
Removes theTransactionXaAdapter
corresponding to the given tx.void
startXidMapping()
-
Methods inherited from class org.infinispan.transaction.impl.TransactionTable
afterCompletion, beforeCompletion, cleanupLeaverTransactions, containRemoteTx, containsLocalTx, failureCompletingTransaction, getCompletedTransactionStatus, getGlobalTransaction, getLocalGlobalTransaction, getLocalTransaction, getLocalTransaction, getLocalTransactions, getMinTopologyId, getOrCreateLocalTransaction, getOrCreateLocalTransaction, getOrCreateRemoteTransaction, getOrCreateRemoteTransaction, getRemoteGlobalTransaction, getRemoteTransaction, getRemoteTransactions, getRemoteTxCount, isTransactionCompleted, localTransactionPrepared, markTransactionCompleted, onTopologyChange, onViewChange, recalculateMinTopologyIdIfNeeded, releaseLocksForCompletedTransaction, remoteTransactionCommitted, remoteTransactionPrepared, remoteTransactionRollback, removeRemoteTransaction, start
-
-
-
-
Field Detail
-
recoveryManager
protected RecoveryManager recoveryManager
-
cacheName
protected String cacheName
-
xid2LocalTx
protected ConcurrentMap<XidImpl,LocalXaTransaction> xid2LocalTx
-
-
Method Detail
-
startXidMapping
public void startXidMapping()
-
removeLocalTransaction
public boolean removeLocalTransaction(LocalTransaction localTx)
Description copied from class:TransactionTable
Removes theTransactionXaAdapter
corresponding to the given tx. Returns true if such an tx exists.- Overrides:
removeLocalTransaction
in classTransactionTable
-
getLocalTransaction
public LocalXaTransaction getLocalTransaction(XidImpl xid)
-
enlist
public void enlist(javax.transaction.Transaction transaction, LocalTransaction ltx)
- Overrides:
enlist
in classTransactionTable
-
enlistClientTransaction
public void enlistClientTransaction(javax.transaction.Transaction transaction, LocalTransaction localTransaction)
- Overrides:
enlistClientTransaction
in classTransactionTable
-
getLocalTxCount
public int getLocalTxCount()
- Overrides:
getLocalTxCount
in classTransactionTable
-
prepare
public CompletionStage<Integer> prepare(XidImpl xid)
-
commit
public CompletionStage<Void> commit(XidImpl xid, boolean isOnePhase)
-
-