public class VersionedReplicationInterceptor extends ReplicationInterceptor
ReplicationInterceptor
that adds additional logic to how prepares are handled.defaultSynchronous, rpcManager
configuration
Constructor and Description |
---|
VersionedReplicationInterceptor() |
Modifier and Type | Method and Description |
---|---|
protected void |
broadcastPrepare(TxInvocationContext context,
PrepareCommand command) |
protected PrepareCommand |
buildPrepareCommandForResend(TxInvocationContext ctx,
CommitCommand commit) |
protected Log |
getLog() |
init, visitClearCommand, visitCommitCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand
init, init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, visitLockControlCommand
getNext, handleDefault, hasNext, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand
protected Log getLog()
getLog
in class ReplicationInterceptor
protected PrepareCommand buildPrepareCommandForResend(TxInvocationContext ctx, CommitCommand commit)
buildPrepareCommandForResend
in class ReplicationInterceptor
protected void broadcastPrepare(TxInvocationContext context, PrepareCommand command)
broadcastPrepare
in class ReplicationInterceptor
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.