org.infinispan.interceptors.impl

Class BaseRpcInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.impl.BaseRpcInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

Direct Known Subclasses:

ClusteringInterceptor, InvalidationInterceptor, L1LastChanceInterceptor, L1NonTxInterceptor

public abstract class BaseRpcInterceptor
extends DDAsyncInterceptor

Acts as a base for all RPC calls

Since:

9.0

Author:

Manik Surtani (manik@jboss.org), Mircea.Markus@jboss.com

Field Summary

Fields

Modifier and Type	Field and Description
protected ComponentRegistry	componentRegistry
protected boolean	defaultSynchronous
protected RpcManager	rpcManager
protected boolean	trace

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
BaseRpcInterceptor()

Method Summary

Modifier and Type	Method and Description
protected abstract Log	getLog()
void	init()
protected boolean	isLocalModeForced(FlagAffectedCommand command)
protected boolean	isSynchronous(FlagAffectedCommand command)
protected boolean	shouldInvokeRemoteTxCommand(TxInvocationContext ctx)
protected static void	transactionRemotelyPrepared(TxInvocationContext ctx)

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitClearCommand, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitEntrySetCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedNull, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.commands.Visitor

visitRemoveExpiredCommand

Field Detail

trace

protected final boolean trace

rpcManager

protected RpcManager rpcManager

componentRegistry

protected ComponentRegistry componentRegistry

defaultSynchronous

protected boolean defaultSynchronous

Constructor Detail

BaseRpcInterceptor

public BaseRpcInterceptor()

Method Detail

getLog

protected abstract Log getLog()

init

public void init()

isSynchronous

protected final boolean isSynchronous(FlagAffectedCommand command)

isLocalModeForced

protected final boolean isLocalModeForced(FlagAffectedCommand command)

shouldInvokeRemoteTxCommand

protected boolean shouldInvokeRemoteTxCommand(TxInvocationContext ctx)

transactionRemotelyPrepared

protected static void transactionRemotelyPrepared(TxInvocationContext ctx)