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 org.infinispan.transaction.impl.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

org.infinispan.transaction.impl.TransactionTable.CompletedTransactionStatus

Field Summary

Fields

Modifier and Type	Field	Description
protected String	cacheName
protected RecoveryManager	recoveryManager
protected ConcurrentMap<Xid,LocalXaTransaction>	xid2LocalTx

Fields inherited from class org.infinispan.transaction.impl.TransactionTable

CACHE_STOPPED_TOPOLOGY_ID, clustered, commandsFactory, configuration, partitionHandlingManager, rpcManager, running, txCoordinator

Constructor Summary

Constructors

Constructor	Description
XaTransactionTable()

Method Summary

Modifier and Type	Method	Description
void	commit(Xid externalXid, boolean isOnePhase)
void	enlist(Transaction transaction, org.infinispan.transaction.impl.LocalTransaction ltx)
void	enlistClientTransaction(Transaction transaction, org.infinispan.transaction.impl.LocalTransaction localTransaction)
LocalXaTransaction	getLocalTransaction(Xid xid)
int	getLocalTxCount()
int	prepare(Xid externalXid)
boolean	removeLocalTransaction(org.infinispan.transaction.impl.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<Xid,LocalXaTransaction> xid2LocalTx

Constructor Detail

XaTransactionTable

public XaTransactionTable()

Method Detail

startXidMapping

public void startXidMapping()

removeLocalTransaction

public boolean removeLocalTransaction(org.infinispan.transaction.impl.LocalTransaction localTx)

Description copied from class: org.infinispan.transaction.impl.TransactionTable

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

Overrides:

removeLocalTransaction in class org.infinispan.transaction.impl.TransactionTable

getLocalTransaction

public LocalXaTransaction getLocalTransaction(Xid xid)

enlist

public void enlist(Transaction transaction,
                   org.infinispan.transaction.impl.LocalTransaction ltx)

Overrides:

enlist in class org.infinispan.transaction.impl.TransactionTable

enlistClientTransaction

public void enlistClientTransaction(Transaction transaction,
                                    org.infinispan.transaction.impl.LocalTransaction localTransaction)

Overrides:

enlistClientTransaction in class org.infinispan.transaction.impl.TransactionTable

getLocalTxCount

public int getLocalTxCount()

Overrides:

getLocalTxCount in class org.infinispan.transaction.impl.TransactionTable

prepare

public int prepare(Xid externalXid)
            throws XAException

Throws:

XAException

commit

public void commit(Xid externalXid,
                   boolean isOnePhase)
            throws XAException

Throws:

XAException