public class NonTxDistributionInterceptor extends BaseDistributionInterceptor
cdl, dm, rvrl
cf, dataContainer, entryFactory, isL1Enabled, lockManager, needReliableReturnValues, stateTransferManager
defaultSynchronous, rpcManager
cacheConfiguration
Constructor and Description |
---|
NonTxDistributionInterceptor() |
Modifier and Type | Method and Description |
---|---|
protected void |
remoteGetBeforeWrite(InvocationContext ctx,
WriteCommand command,
org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator keygen) |
Object |
visitClearCommand(InvocationContext ctx,
ClearCommand command)
Don't forward in the case of clear commands, just acquire local locks and broadcast.
|
Object |
visitGetKeyValueCommand(InvocationContext ctx,
GetKeyValueCommand command) |
Object |
visitPutKeyValueCommand(InvocationContext ctx,
PutKeyValueCommand command) |
Object |
visitPutMapCommand(InvocationContext ctx,
PutMapCommand command) |
Object |
visitRemoveCommand(InvocationContext ctx,
RemoveCommand command) |
Object |
visitReplaceCommand(InvocationContext ctx,
ReplaceCommand command) |
getLog, handleNonTxWriteCommand, injectDependencies, retrieveFromRemoteSource
configure, ignorePreviousValueOnBackup, injectDependencies, isNeedReliableReturnValues, isValueAvailableLocally, needsRemoteGet
getIgnoreExtraResponseFilter, getSelfDeliverFilter, init, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderAnycastPrepare, totalOrderBroadcastPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared
getLockAcquisitionTimeout, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand
public Object visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable
visitGetKeyValueCommand
in interface Visitor
visitGetKeyValueCommand
in class AbstractVisitor
Throwable
public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable
visitPutKeyValueCommand
in interface Visitor
visitPutKeyValueCommand
in class AbstractVisitor
Throwable
public Object visitPutMapCommand(InvocationContext ctx, PutMapCommand command) throws Throwable
visitPutMapCommand
in interface Visitor
visitPutMapCommand
in class AbstractVisitor
Throwable
public Object visitRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable
visitRemoveCommand
in interface Visitor
visitRemoveCommand
in class AbstractVisitor
Throwable
public Object visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable
visitReplaceCommand
in interface Visitor
visitReplaceCommand
in class AbstractVisitor
Throwable
public Object visitClearCommand(InvocationContext ctx, ClearCommand command) throws Throwable
visitClearCommand
in interface Visitor
visitClearCommand
in class AbstractVisitor
Throwable
protected void remoteGetBeforeWrite(InvocationContext ctx, WriteCommand command, org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator keygen) throws Throwable
remoteGetBeforeWrite
in class BaseDistributionInterceptor
Throwable
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.