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
AnAction
implementation 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 void
addListener(ActionListener listener)
Adds a listener to be invoked when this action is ready or canceled.protected ActionStatus
checking(ActionState state)
protected ActionStatus
init(ActionState state)
void
onReady()
Invoked whenPendingLockPromise
is 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:
checking
in classBaseLockingAction
-
init
protected ActionStatus init(ActionState state)
- Specified by:
init
in classBaseLockingAction
-
addListener
public void addListener(ActionListener listener)
Description copied from interface:Action
Adds a listener to be invoked when this action is ready or canceled.- Specified by:
addListener
in interfaceAction
- Parameters:
listener
- theActionListener
to add.
-
onReady
public void onReady()
Description copied from interface:PendingLockListener
Invoked whenPendingLockPromise
is ready.- Specified by:
onReady
in interfacePendingLockListener
-
-