org.infinispan.interceptors.base

Class BaseStateTransferInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.base.BaseStateTransferInterceptor

public abstract class BaseStateTransferInterceptor
extends CommandInterceptor

A base class for a state transfer interceptor. It contains the base code to avoid duplicating in the two current different implementations.

Also, it has some utilities methods with the most common logic.

Since:

7.0

Author:

Pedro Ruivo

Field Summary

Fields

Modifier and Type	Field and Description
protected StateTransferManager	stateTransferManager

Fields inherited from class org.infinispan.interceptors.base.CommandInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
BaseStateTransferInterceptor()

Method Summary

Methods

Modifier and Type	Method and Description
protected int	currentTopologyId()
void	init(StateTransferLock stateTransferLock, Configuration configuration, StateTransferManager stateTransferManager, GroupManager groupManager)
protected void	logRetry(VisitableCommand command)
protected void	updateTopologyId(TopologyAffectedCommand command)
Object	visitGetKeysInGroupCommand(InvocationContext ctx, GetKeysInGroupCommand command)
protected void	waitForTransactionData(int topologyId)

Methods inherited from class org.infinispan.interceptors.base.CommandInterceptor

getLockAcquisitionTimeout, getLog, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext

Field Detail

stateTransferManager

protected StateTransferManager stateTransferManager

Constructor Detail

BaseStateTransferInterceptor

public BaseStateTransferInterceptor()

Method Detail

init

public void init(StateTransferLock stateTransferLock,
        Configuration configuration,
        StateTransferManager stateTransferManager,
        GroupManager groupManager)

visitGetKeysInGroupCommand

public Object visitGetKeysInGroupCommand(InvocationContext ctx,
                                GetKeysInGroupCommand command)

Overrides:

visitGetKeysInGroupCommand in class AbstractVisitor

logRetry

protected final void logRetry(VisitableCommand command)

currentTopologyId

protected final int currentTopologyId()

waitForTransactionData

protected final void waitForTransactionData(int topologyId)

updateTopologyId

protected final void updateTopologyId(TopologyAffectedCommand command)