public class L1NonTxInterceptor extends BaseRpcInterceptor
Modifier and Type | Field and Description |
---|---|
protected ClusteringDependentLogic |
cdl |
protected CommandsFactory |
commandsFactory |
protected InternalDataContainer |
dataContainer |
protected EntryFactory |
entryFactory |
protected KeyPartitioner |
keyPartitioner |
protected L1Manager |
l1Manager |
protected StateTransferLock |
stateTransferLock |
componentRegistry, defaultSynchronous, rpcManager
cacheConfiguration
Constructor and Description |
---|
L1NonTxInterceptor() |
init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, transactionRemotelyPrepared
handleDefault, visitClearCommand, visitCommand, visitCommitCommand, visitEntrySetCommand, visitEvictCommand, visitGetAllCommand, visitGetKeysInGroupCommand, visitInvalidateCommand, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand
asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedNull, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
visitRemoveExpiredCommand
protected L1Manager l1Manager
protected ClusteringDependentLogic cdl
protected EntryFactory entryFactory
protected CommandsFactory commandsFactory
protected InternalDataContainer dataContainer
protected StateTransferLock stateTransferLock
protected KeyPartitioner keyPartitioner
public void start()
public final Object visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable
visitGetKeyValueCommand
in interface Visitor
visitGetKeyValueCommand
in class DDAsyncInterceptor
Throwable
public final Object visitGetCacheEntryCommand(InvocationContext ctx, GetCacheEntryCommand command) throws Throwable
visitGetCacheEntryCommand
in interface Visitor
visitGetCacheEntryCommand
in class DDAsyncInterceptor
Throwable
protected Object performCommandWithL1WriteIfAble(InvocationContext ctx, DataCommand command, boolean isEntry, boolean shouldAlwaysRunNextInterceptor, boolean registerL1) throws Throwable
Throwable
protected boolean skipL1Lookup(FlagAffectedCommand command, Object key)
public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable
visitPutKeyValueCommand
in interface Visitor
visitPutKeyValueCommand
in class DDAsyncInterceptor
Throwable
public Object visitWriteOnlyKeyCommand(InvocationContext ctx, WriteOnlyKeyCommand command) throws Throwable
visitWriteOnlyKeyCommand
in interface Visitor
visitWriteOnlyKeyCommand
in class DDAsyncInterceptor
Throwable
public Object visitReadWriteKeyValueCommand(InvocationContext ctx, ReadWriteKeyValueCommand command) throws Throwable
visitReadWriteKeyValueCommand
in interface Visitor
visitReadWriteKeyValueCommand
in class DDAsyncInterceptor
Throwable
public Object visitReadWriteKeyCommand(InvocationContext ctx, ReadWriteKeyCommand command) throws Throwable
visitReadWriteKeyCommand
in interface Visitor
visitReadWriteKeyCommand
in class DDAsyncInterceptor
Throwable
public Object visitWriteOnlyManyEntriesCommand(InvocationContext ctx, WriteOnlyManyEntriesCommand command) throws Throwable
visitWriteOnlyManyEntriesCommand
in interface Visitor
visitWriteOnlyManyEntriesCommand
in class DDAsyncInterceptor
Throwable
public Object visitWriteOnlyKeyValueCommand(InvocationContext ctx, WriteOnlyKeyValueCommand command) throws Throwable
visitWriteOnlyKeyValueCommand
in interface Visitor
visitWriteOnlyKeyValueCommand
in class DDAsyncInterceptor
Throwable
public Object visitWriteOnlyManyCommand(InvocationContext ctx, WriteOnlyManyCommand command) throws Throwable
visitWriteOnlyManyCommand
in interface Visitor
visitWriteOnlyManyCommand
in class DDAsyncInterceptor
Throwable
public Object visitReadWriteManyCommand(InvocationContext ctx, ReadWriteManyCommand command) throws Throwable
visitReadWriteManyCommand
in interface Visitor
visitReadWriteManyCommand
in class DDAsyncInterceptor
Throwable
public Object visitReadWriteManyEntriesCommand(InvocationContext ctx, ReadWriteManyEntriesCommand command) throws Throwable
visitReadWriteManyEntriesCommand
in interface Visitor
visitReadWriteManyEntriesCommand
in class DDAsyncInterceptor
Throwable
public Object visitRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable
visitRemoveCommand
in interface Visitor
visitRemoveCommand
in class DDAsyncInterceptor
Throwable
public Object visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable
visitReplaceCommand
in interface Visitor
visitReplaceCommand
in class DDAsyncInterceptor
Throwable
public Object visitComputeCommand(InvocationContext ctx, ComputeCommand command) throws Throwable
visitComputeCommand
in interface Visitor
visitComputeCommand
in class DDAsyncInterceptor
Throwable
public Object visitComputeIfAbsentCommand(InvocationContext ctx, ComputeIfAbsentCommand command) throws Throwable
visitComputeIfAbsentCommand
in interface Visitor
visitComputeIfAbsentCommand
in class DDAsyncInterceptor
Throwable
public Object visitPutMapCommand(InvocationContext ctx, PutMapCommand command) throws Throwable
visitPutMapCommand
in interface Visitor
visitPutMapCommand
in class DDAsyncInterceptor
Throwable
public Object visitInvalidateL1Command(InvocationContext ctx, InvalidateL1Command invalidateL1Command) throws Throwable
visitInvalidateL1Command
in interface Visitor
visitInvalidateL1Command
in class DDAsyncInterceptor
Throwable
protected Log getLog()
getLog
in class BaseRpcInterceptor
Copyright © 2021 JBoss by Red Hat. All rights reserved.