public class VersionedDistributionInterceptor extends DistributionInterceptor
DistributionInterceptor
that adds logic to handling prepares when entries are versioned.defaultSynchronous, rpcManager
configuration
Constructor and Description |
---|
VersionedDistributionInterceptor() |
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) |
injectDependencies, start, visitClearCommand, visitCommitCommand, visitGetKeyValueCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand
init, init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand
getNext, handleDefault, hasNext, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand
protected Log getLog()
getLog
in class DistributionInterceptor
protected PrepareCommand buildPrepareCommandForResend(TxInvocationContext ctx, CommitCommand commit)
buildPrepareCommandForResend
in class DistributionInterceptor
protected void prepareOnAffectedNodes(TxInvocationContext ctx, PrepareCommand command, Collection<Address> recipients, boolean ignored)
prepareOnAffectedNodes
in class DistributionInterceptor
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.