Class PendingTxAction
- java.lang.Object
-
- org.infinispan.remoting.inboundhandler.action.BaseLockingAction
-
- org.infinispan.remoting.inboundhandler.action.PendingTxAction
-
- All Implemented Interfaces:
Action,PendingLockListener
public class PendingTxAction extends BaseLockingAction implements PendingLockListener
AnActionimplementation that check for older topology transactions. This action is ready when no older topology transactions exists or is canceled when the timeout occurs.- Since:
- 8.0
- Author:
- Pedro Ruivo
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.infinispan.remoting.inboundhandler.action.BaseLockingAction
BaseLockingAction.InternalState
-
-
Constructor Summary
Constructors Constructor Description PendingTxAction(PendingLockManager pendingLockManager, DistributionManager distributionManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddListener(ActionListener listener)Adds a listener to be invoked when this action is ready or canceled.protected ActionStatuschecking(ActionState state)protected ActionStatusinit(ActionState state)voidonReady()Invoked whenPendingLockPromiseis ready.-
Methods inherited from class org.infinispan.remoting.inboundhandler.action.BaseLockingAction
cas, check, getAndUpdateFilteredKeys
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.infinispan.remoting.inboundhandler.action.Action
onException, onFinally
-
-
-
-
Constructor Detail
-
PendingTxAction
public PendingTxAction(PendingLockManager pendingLockManager, DistributionManager distributionManager)
-
-
Method Detail
-
checking
protected ActionStatus checking(ActionState state)
- Specified by:
checkingin classBaseLockingAction
-
init
protected ActionStatus init(ActionState state)
- Specified by:
initin classBaseLockingAction
-
addListener
public void addListener(ActionListener listener)
Description copied from interface:ActionAdds a listener to be invoked when this action is ready or canceled.- Specified by:
addListenerin interfaceAction- Parameters:
listener- theActionListenerto add.
-
onReady
public void onReady()
Description copied from interface:PendingLockListenerInvoked whenPendingLockPromiseis ready.- Specified by:
onReadyin interfacePendingLockListener
-
-