org.infinispan.interceptors

Class VersionedDistributionInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.base.BaseRpcInterceptor

org.infinispan.interceptors.DistributionInterceptor

org.infinispan.interceptors.VersionedDistributionInterceptor

All Implemented Interfaces:

Visitor

public class VersionedDistributionInterceptor
extends DistributionInterceptor

A version of the DistributionInterceptor that adds logic to handling prepares when entries are versioned.

Since:

5.1

Author:

Manik Surtani

Field Summary

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

defaultSynchronous, rpcManager

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

configuration

Constructor Summary

Constructors

Constructor and Description
VersionedDistributionInterceptor()

Method Summary

Methods

Modifier and Type	Method and Description
protected PrepareCommand	buildPrepareCommandForResend(TxInvocationContext ctx, CommitCommand commit)
protected Log	getLog()
protected void	prepareOnAffectedNodes(TxInvocationContext ctx, PrepareCommand command, Collection<Address> recipients, boolean ignored)

Methods inherited from class org.infinispan.interceptors.DistributionInterceptor

injectDependencies, start, visitClearCommand, visitCommitCommand, visitGetKeyValueCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand

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

init, init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand

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

getNext, handleDefault, hasNext, invokeNextInterceptor, setNext

Methods inherited from class org.infinispan.commands.AbstractVisitor

visitApplyDeltaCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand

Methods inherited from class java.lang.Object

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

Constructor Detail

VersionedDistributionInterceptor

public VersionedDistributionInterceptor()

Method Detail

getLog

protected Log getLog()

Overrides:

getLog in class DistributionInterceptor

buildPrepareCommandForResend

protected PrepareCommand buildPrepareCommandForResend(TxInvocationContext ctx,
                                          CommitCommand commit)

Overrides:

buildPrepareCommandForResend in class DistributionInterceptor

prepareOnAffectedNodes

protected void prepareOnAffectedNodes(TxInvocationContext ctx,
                          PrepareCommand command,
                          Collection<Address> recipients,
                          boolean ignored)

Overrides:

prepareOnAffectedNodes in class DistributionInterceptor