Class RecoveryAwareLocalTransaction
java.lang.Object
org.infinispan.transaction.impl.AbstractCacheTransaction
org.infinispan.transaction.impl.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
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.infinispan.transaction.xa.CacheTransaction
CacheTransaction.TransactionCompletedListener
-
Field Summary
Fields inherited from class org.infinispan.transaction.impl.AbstractCacheTransaction
affectedKeys, lookedUpEntries, modifications, topologyId, tx
-
Constructor Summary
ConstructorDescriptionRecoveryAwareLocalTransaction
(javax.transaction.Transaction transaction, GlobalTransaction tx, boolean implicitTransaction, int topologyId, long txCreationTime) -
Method Summary
Modifier and TypeMethodDescriptionboolean
Returns true if this transaction failed during 2nd phase of 2PC(prepare or commit).boolean
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.impl.LocalTransaction
addModification, clearRemoteLocksAcquired, equals, getCommitNodes, getIracMetadata, getLookedUpEntries, getRemoteLocksAcquired, getTransaction, hashCode, hasIracMetadata, isFromRemoteSite, isImplicitTransaction, isPrepareSent, isReadOnly, locksAcquired, markPrepareSent, putLookedUpEntries, putLookedUpEntry, setFromRemoteSite, setStateTransferFlag, storeIracMetadata
Methods inherited from class org.infinispan.transaction.impl.AbstractCacheTransaction
addAffectedKey, addAllAffectedKeys, addBackupLockForKey, addListener, addVersionRead, checkIfRolledBack, cleanupBackupLocks, clearLockedKeys, clearLookedUpEntries, forEachBackupLock, forEachLock, freezeModifications, getAffectedKeys, getAllModifications, getBackupLockedKeys, getCreationTime, getGlobalTransaction, getLockedKeys, getModifications, getReleaseFutureForKey, getReleaseFutureForKeys, getStateTransferFlag, getTopologyId, getUpdatedEntryVersions, getVersionsRead, hasModifications, isFromStateTransfer, isMarkedForRollback, lookupEntry, markForRollback, notifyOnTransactionFinished, ownsLock, registerLockedKey, removeBackupLock, removeBackupLocks, removeLookedUpEntry, setModifications, setUpdatedEntryVersions
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, addListener, addVersionRead, cleanupBackupLocks, clearLockedKeys, clearLookedUpEntries, forEachBackupLock, forEachLock, freezeModifications, getAllModifications, getCreationTime, getGlobalTransaction, getLockedKeys, getLookedUpEntries, getModifications, getReleaseFutureForKey, getReleaseFutureForKeys, getTopologyId, getUpdatedEntryVersions, getVersionsRead, hasModification, isMarkedForRollback, lookupEntry, markForRollback, notifyOnTransactionFinished, ownsLock, putLookedUpEntries, putLookedUpEntry, removeBackupLock, removeBackupLocks, removeLookedUpEntry, setUpdatedEntryVersions
-
Constructor Details
-
RecoveryAwareLocalTransaction
public RecoveryAwareLocalTransaction(javax.transaction.Transaction transaction, GlobalTransaction tx, boolean implicitTransaction, int topologyId, long txCreationTime)
-
-
Method Details
-
isPrepared
public boolean isPrepared()- Specified by:
isPrepared
in interfaceRecoveryAwareTransaction
-
setPrepared
public void setPrepared(boolean prepared) - Specified by:
setPrepared
in interfaceRecoveryAwareTransaction
-
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:
-