public class TxDistributionInterceptor extends BaseDistributionInterceptor
cdl, dmcf, dataContainer, entryFactory, lockManager, needReliableReturnValues, stateTransferManagerdefaultSynchronous, rpcManagercacheConfiguration| Constructor and Description |
|---|
TxDistributionInterceptor() |
getLog, injectDependencies, isSingleOwnerAndLocal, retrieveFromRemoteSource, visitPutMapCommandconfigure, 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, visitValuesCommandpublic void init(L1Manager l1Manager)
public Object visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable
visitReplaceCommand in interface VisitorvisitReplaceCommand in class BaseDistributionInterceptorThrowablepublic Object visitRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable
visitRemoveCommand in interface VisitorvisitRemoveCommand in class BaseDistributionInterceptorThrowableprotected boolean ignorePreviousValueOnBackup(WriteCommand command, InvocationContext ctx)
- node A (owner, tx originator) does a successful replace - the actual value changes - tx commits. The value is applied on A (the check was performed at operation time) but is not applied on B (check is performed at commit time). In such situations (optimistic caches) the remote conditional command should not re-check the old value.
ignorePreviousValueOnBackup in class ClusteringInterceptorpublic void start()
public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable
visitPutKeyValueCommand in interface VisitorvisitPutKeyValueCommand in class AbstractVisitorThrowablepublic Object visitClearCommand(InvocationContext ctx, ClearCommand command) throws Throwable
visitClearCommand in interface VisitorvisitClearCommand 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 AbstractVisitorThrowablepublic Object visitCommitCommand(TxInvocationContext ctx, CommitCommand command) throws Throwable
visitCommitCommand in interface VisitorvisitCommitCommand in class AbstractVisitorThrowablepublic Object visitPrepareCommand(TxInvocationContext ctx, PrepareCommand command) throws Throwable
visitPrepareCommand in interface VisitorvisitPrepareCommand in class AbstractVisitorThrowableprotected void prepareOnAffectedNodes(TxInvocationContext ctx, PrepareCommand command, Collection<Address> recipients, boolean sync)
public Object visitRollbackCommand(TxInvocationContext ctx, RollbackCommand command) throws Throwable
visitRollbackCommand in interface VisitorvisitRollbackCommand in class AbstractVisitorThrowableprotected void sendCommitCommand(TxInvocationContext ctx, CommitCommand command) throws TimeoutException, InterruptedException
TimeoutExceptionInterruptedExceptionprotected void checkTxCommandResponses(Map<Address,Response> responseMap, TransactionBoundaryCommand command)
protected Object handleWriteCommand(InvocationContext ctx, WriteCommand command, org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator recipientGenerator, boolean skipRemoteGet, boolean skipL1Invalidation) throws Throwable
handleWriteCommand in class BaseDistributionInterceptorThrowableprotected Future<?> flushL1Caches(InvocationContext ctx)
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.