org.infinispan.transaction.xa.recovery

Class RecoveryAwareLocalTransaction

java.lang.Object

org.infinispan.transaction.AbstractCacheTransaction

org.infinispan.transaction.LocalTransaction

org.infinispan.transaction.xa.LocalXaTransaction

org.infinispan.transaction.xa.recovery.RecoveryAwareLocalTransaction

All Implemented Interfaces:

CacheTransaction, RecoveryAwareTransaction

public class RecoveryAwareLocalTransaction
extends LocalXaTransaction
implements RecoveryAwareTransaction

Extends LocalXaTransaction and adds recovery related information.

Since:

5.0

Author:

Mircea.Markus@jboss.com

Field Summary

Fields inherited from class org.infinispan.transaction.AbstractCacheTransaction

affectedKeys, backupKeyLocks, hasLocalOnlyModifications, keyEquivalence, lockedKeys, lookedUpEntries, modifications, topologyId, tx

Constructor Summary

Constructors

Constructor and Description
RecoveryAwareLocalTransaction(Transaction transaction, GlobalTransaction tx, boolean implicitTransaction, int topologyId, Equivalence<Object> keyEquivalence)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isCompletionFailed() Returns true if this transaction failed during 2nd phase of 2PC(prepare or commit).
boolean	isPrepared()
void	setCompletionFailed(boolean completionFailed)
void	setPrepared(boolean prepared)

Methods inherited from class org.infinispan.transaction.xa.LocalXaTransaction

getXid, isEnlisted, setXid, toString

Methods inherited from class org.infinispan.transaction.LocalTransaction

addModification, addReadKey, clearRemoteLocksAcquired, equals, getCommitNodes, getLookedUpEntries, getRemoteLocksAcquired, getTransaction, hashCode, isCommitOrRollbackSent, isFromRemoteSite, isFromStateTransfer, isImplicitTransaction, isPrepareSent, isReadOnly, keyRead, locksAcquired, markCommitOrRollbackSent, markPrepareSent, putLookedUpEntries, putLookedUpEntry, setFromRemoteSite, setFromStateTransfer

Methods inherited from class org.infinispan.transaction.AbstractCacheTransaction

addAffectedKey, addAllAffectedKeys, addBackupLockForKey, addVersionRead, clearLockedKeys, clearLookedUpEntries, getAffectedKeys, getAllModifications, getBackupLockedKeys, getGlobalTransaction, getLockedKeys, getLookedUpRemoteVersion, getModifications, getTopologyId, getUpdatedEntryVersions, getVersionsRead, hasModification, isMarkedForRollback, lookupEntry, markForRollback, notifyOnTransactionFinished, ownsLock, putLookedUpRemoteVersion, registerLockedKey, removeLookedUpEntry, replaceVersionRead, setModifications, setUpdatedEntryVersions, waitForLockRelease

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.infinispan.transaction.xa.CacheTransaction

addBackupLockForKey, addReadKey, addVersionRead, clearLockedKeys, clearLookedUpEntries, getAllModifications, getBackupLockedKeys, getGlobalTransaction, getLockedKeys, getLookedUpEntries, getLookedUpRemoteVersion, getModifications, getTopologyId, getUpdatedEntryVersions, getVersionsRead, hasModification, isMarkedForRollback, keyRead, lookupEntry, markForRollback, notifyOnTransactionFinished, ownsLock, putLookedUpEntries, putLookedUpEntry, putLookedUpRemoteVersion, removeLookedUpEntry, replaceVersionRead, setUpdatedEntryVersions, waitForLockRelease

Constructor Detail

RecoveryAwareLocalTransaction

public RecoveryAwareLocalTransaction(Transaction transaction,
                             GlobalTransaction tx,
                             boolean implicitTransaction,
                             int topologyId,
                             Equivalence<Object> keyEquivalence)

Method Detail

isPrepared

public boolean isPrepared()

Specified by:

isPrepared in interface RecoveryAwareTransaction

setPrepared

public void setPrepared(boolean prepared)

Specified by:

setPrepared in interface RecoveryAwareTransaction

isCompletionFailed

public boolean isCompletionFailed()

Returns true if this transaction failed during 2nd phase of 2PC(prepare or commit). E.g. when the transaction successfully prepared but the commit failed due to a network issue.

setCompletionFailed

public void setCompletionFailed(boolean completionFailed)

See Also:

isCompletionFailed()