|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.transaction.TransactionTable
org.infinispan.transaction.xa.XaTransactionTable
org.infinispan.transaction.xa.recovery.RecoveryAwareTransactionTable
public class RecoveryAwareTransactionTable
Transaction table that delegates prepared transaction's management to the RecoveryManager
.
Field Summary |
---|
Fields inherited from class org.infinispan.transaction.xa.XaTransactionTable |
---|
xid2LocalTx |
Fields inherited from class org.infinispan.transaction.TransactionTable |
---|
CACHE_STOPPED_VIEW_ID, clustered, clusteringLogic, commandsFactory, configuration, icc, rpcManager, txCoordinator, txFactory |
Constructor Summary | |
---|---|
RecoveryAwareTransactionTable()
|
Method Summary | |
---|---|
void |
failureCompletingTransaction(Transaction tx)
|
List<Xid> |
getLocalPreparedXids()
|
Set<RecoveryAwareLocalTransaction> |
getLocalTxThatFailedToComplete()
|
RemoteTransaction |
getRemoteTransaction(GlobalTransaction txId)
Returns the RemoteTransaction associated with the supplied transaction id. |
Xid |
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 |
initialize(RecoveryManager recoveryManager)
|
void |
localTransactionPrepared(LocalTransaction localTransaction)
|
void |
remoteTransactionCommitted(GlobalTransaction gtx)
Removes the RemoteTransaction corresponding to the given tx. |
void |
remoteTransactionPrepared(GlobalTransaction gtx)
Marks the transaction as prepared. |
void |
remoteTransactionRollback(GlobalTransaction gtx)
|
RemoteTransaction |
removeRemoteTransaction(Xid xid)
|
protected void |
updateStateOnNodesLeaving(Collection<Address> leavers)
First moves the prepared transactions originated on the leavers into the recovery cache and then cleans up the transactions that are not yet prepared. |
Methods inherited from class org.infinispan.transaction.xa.XaTransactionTable |
---|
addLocalTransactionMapping, enlist, getLocalTransaction, getLocalTxCount, getRecoveryManager, init, removeLocalTransaction, removeLocalTransaction, setRecoveryManager |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RecoveryAwareTransactionTable()
Method Detail |
---|
public void initialize(RecoveryManager recoveryManager)
public void remoteTransactionPrepared(GlobalTransaction gtx)
updateStateOnNodesLeaving(java.util.Collection)
remoteTransactionPrepared
in class TransactionTable
public void localTransactionPrepared(LocalTransaction localTransaction)
localTransactionPrepared
in class TransactionTable
localTransactionPrepared(org.infinispan.transaction.LocalTransaction)
protected void updateStateOnNodesLeaving(Collection<Address> leavers)
updateStateOnNodesLeaving
in class TransactionTable
public 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)
TransactionTable
RemoteTransaction
corresponding to the given tx.
remoteTransactionCommitted
in class TransactionTable
public List<Xid> getLocalPreparedXids()
public void failureCompletingTransaction(Transaction tx)
failureCompletingTransaction
in class TransactionTable
public Set<RecoveryAwareLocalTransaction> getLocalTxThatFailedToComplete()
public Xid getRemoteTransactionXid(Long internalId)
public RemoteTransaction removeRemoteTransaction(Xid xid)
|
--> | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |