public class VersionedReplicationInterceptor extends ReplicationInterceptor
ReplicationInterceptor
that adds additional logic to how prepares are handled.cf, dataContainer, entryFactory, lockManager, needReliableReturnValues, stateTransferManager
defaultSynchronous, rpcManager
cacheConfiguration
Constructor and Description |
---|
VersionedReplicationInterceptor() |
Modifier and Type | Method and Description |
---|---|
protected void |
broadcastPrepare(TxInvocationContext context,
PrepareCommand command) |
protected Log |
getLog() |
checkTxCommandResponses, getPrimaryOwner, retrieveFromRemoteSource, start, visitClearCommand, visitCommitCommand, visitGetKeyValueCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand
configure, ignorePreviousValueOnBackup, injectDependencies, isNeedReliableReturnValues, needsRemoteGet
init, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, transactionRemotelyPrepared
getLockAcquisitionTimeout, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand
protected Log getLog()
getLog
in class ReplicationInterceptor
protected void broadcastPrepare(TxInvocationContext context, PrepareCommand command)
broadcastPrepare
in class ReplicationInterceptor
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.