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

VersionedDistributionInterceptor()

Method Summary

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