Package 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	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	Description
BaseRpcInterceptor()

Method Summary

Modifier and Type	Method	Description
protected abstract Log	getLog()
void	init()
protected boolean	isLocalModeForced(FlagAffectedCommand command)
protected boolean	isSynchronous(FlagAffectedCommand command)
protected boolean	shouldInvokeRemoteTxCommand(TxInvocationContext ctx)
protected static boolean	shouldTotalOrderRollbackBeInvokedRemotely(TxInvocationContext ctx)
protected CompletionStage<Object>	totalOrderPrepare(TxInvocationContext<?> ctx, org.infinispan.commands.tx.PrepareCommand command, Collection<Address> recipients)
protected static void	totalOrderTxCommit(TxInvocationContext ctx)
protected static void	totalOrderTxRollback(TxInvocationContext ctx)
protected static void	transactionRemotelyPrepared(TxInvocationContext ctx)

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitClearCommand, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitDistributedExecuteCommand, 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, 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

visitApplyDeltaCommand, 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)

totalOrderTxCommit

protected static void totalOrderTxCommit(TxInvocationContext ctx)

totalOrderTxRollback

protected static void totalOrderTxRollback(TxInvocationContext ctx)

shouldTotalOrderRollbackBeInvokedRemotely

protected static boolean shouldTotalOrderRollbackBeInvokedRemotely(TxInvocationContext ctx)

totalOrderPrepare

protected CompletionStage<Object> totalOrderPrepare(TxInvocationContext<?> ctx,
                                                    org.infinispan.commands.tx.PrepareCommand command,
                                                    Collection<Address> recipients)