public class ReplicationInterceptor extends ClusteringInterceptor
cf, dataContainer, entryFactory, lockManager, needReliableReturnValues, stateTransferManagerdefaultSynchronous, rpcManagercacheConfiguration| Constructor and Description |
|---|
ReplicationInterceptor() |
configure, ignorePreviousValueOnBackup, injectDependencies, isNeedReliableReturnValues, needsRemoteGetinit, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, transactionRemotelyPreparedgetLockAcquisitionTimeout, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNextvisitApplyDeltaCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommandprotected Log getLog()
getLog in class CommandInterceptorpublic void start()
public Object visitCommitCommand(TxInvocationContext ctx, CommitCommand command) throws Throwable
visitCommitCommand in interface VisitorvisitCommitCommand in class AbstractVisitorThrowableprotected void checkTxCommandResponses(Map<Address,Response> responseMap, TransactionBoundaryCommand command)
public Object visitPrepareCommand(TxInvocationContext ctx, PrepareCommand command) throws Throwable
visitPrepareCommand in interface VisitorvisitPrepareCommand in class AbstractVisitorThrowableprotected void broadcastPrepare(TxInvocationContext context, PrepareCommand command)
public Object visitRollbackCommand(TxInvocationContext ctx, RollbackCommand command) throws Throwable
visitRollbackCommand in interface VisitorvisitRollbackCommand in class AbstractVisitorThrowablepublic Object visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable
visitGetKeyValueCommand in interface VisitorvisitGetKeyValueCommand in class AbstractVisitorThrowablepublic Object visitLockControlCommand(TxInvocationContext ctx, LockControlCommand command) throws Throwable
visitLockControlCommand in interface VisitorvisitLockControlCommand in class AbstractVisitorThrowableprotected Address getPrimaryOwner()
protected InternalCacheEntry retrieveFromRemoteSource(Object key, InvocationContext ctx, boolean acquireRemoteLock, FlagAffectedCommand command)
ClusteringInterceptorClusteredGetCommand
and some form of quorum of responses if the responses returned are inconsistent - often the case if there is a
rehash in progress, involving nodes that the key maps to.retrieveFromRemoteSource in class ClusteringInterceptorkey - key to look uppublic Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable
visitPutKeyValueCommand in interface VisitorvisitPutKeyValueCommand in class AbstractVisitorThrowablepublic Object visitPutMapCommand(InvocationContext ctx, PutMapCommand command) throws Throwable
visitPutMapCommand in interface VisitorvisitPutMapCommand in class AbstractVisitorThrowablepublic Object visitRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable
visitRemoveCommand in interface VisitorvisitRemoveCommand in class AbstractVisitorThrowablepublic Object visitClearCommand(InvocationContext ctx, ClearCommand command) throws Throwable
visitClearCommand in interface VisitorvisitClearCommand in class AbstractVisitorThrowablepublic Object visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable
visitReplaceCommand in interface VisitorvisitReplaceCommand in class AbstractVisitorThrowableCopyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.