org.infinispan.remoting.inboundhandler.action

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

An Action 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 and Description
PendingTxAction(PendingLockManager pendingLockManager, ClusteringDependentLogic clusteringDependentLogic)

Method Summary

Modifier and Type	Method and 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 when PendingLockPromise is ready.

Methods inherited from class org.infinispan.remoting.inboundhandler.action.BaseLockingAction

cas, check, cleanup, getAndUpdateFilteredKeys

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PendingTxAction

public PendingTxAction(PendingLockManager pendingLockManager,
                       ClusteringDependentLogic clusteringDependentLogic)

Method Detail

checking

protected ActionStatus checking(ActionState state)

Specified by:

checking in class BaseLockingAction

init

protected ActionStatus init(ActionState state)

Specified by:

init in class BaseLockingAction

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 interface Action

Parameters:

listener - the ActionListener to add.

onReady

public void onReady()

Description copied from interface: PendingLockListener

Invoked when PendingLockPromise is ready.

Specified by:

onReady in interface PendingLockListener