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 with TransactionXaAdapter.

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 and 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 and Description
XaTransactionTable()

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	commit(XidImpl xid, boolean isOnePhase)
void	enlist(Transaction transaction, LocalTransaction ltx)
void	enlistClientTransaction(Transaction transaction, LocalTransaction localTransaction)
LocalXaTransaction	getLocalTransaction(XidImpl xid)
int	getLocalTxCount()
CompletionStage<Integer>	prepare(XidImpl xid)
boolean	removeLocalTransaction(LocalTransaction localTx) Removes the TransactionXaAdapter 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, getRemoteGlobalTransaction, getRemoteTransaction, getRemoteTransactions, getRemoteTxCount, isTransactionCompleted, localTransactionPrepared, markTransactionCompleted, onTopologyChange, onViewChange, recalculateMinTopologyIdIfNeeded, releaseLocksForCompletedTransaction, remoteTransactionCommitted, remoteTransactionPrepared, remoteTransactionRollback, removeRemoteTransaction, start

Methods inherited from class java.lang.Object

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

Field Detail

recoveryManager

protected RecoveryManager recoveryManager

cacheName

protected String cacheName

xid2LocalTx

protected ConcurrentMap<XidImpl,LocalXaTransaction> xid2LocalTx

Constructor Detail

XaTransactionTable

public XaTransactionTable()

Method Detail

startXidMapping

public void startXidMapping()

removeLocalTransaction

public boolean removeLocalTransaction(LocalTransaction localTx)

Description copied from class: TransactionTable

Removes the TransactionXaAdapter corresponding to the given tx. Returns true if such an tx exists.

Overrides:

removeLocalTransaction in class TransactionTable

getLocalTransaction

public LocalXaTransaction getLocalTransaction(XidImpl xid)

enlist

public void enlist(Transaction transaction,
                   LocalTransaction ltx)

Overrides:

enlist in class TransactionTable

enlistClientTransaction

public void enlistClientTransaction(Transaction transaction,
                                    LocalTransaction localTransaction)

Overrides:

enlistClientTransaction in class TransactionTable

getLocalTxCount

public int getLocalTxCount()

Overrides:

getLocalTxCount in class TransactionTable

prepare

public CompletionStage<Integer> prepare(XidImpl xid)

commit

public CompletionStage<Void> commit(XidImpl xid,
                                    boolean isOnePhase)