org.infinispan.interceptors.base

Class BaseRpcInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.base.BaseRpcInterceptor

public abstract class BaseRpcInterceptor
extends CommandInterceptor

Acts as a base for all RPC calls

Since:

4.0

Author:

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

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	defaultSynchronous
protected RpcManager	rpcManager

Fields inherited from class org.infinispan.interceptors.base.CommandInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
BaseRpcInterceptor()

Method Summary

Methods

Modifier and Type	Method and Description
protected TimeoutValidationResponseFilter	getSelfDeliverFilter()
void	init()
void	inject(RpcManager rpcManager, StateConsumer stateConsumer)
protected boolean	isLocalModeForced(FlagAffectedCommand command)
protected boolean	isSyncCommitPhase()
protected boolean	isSynchronous(FlagAffectedCommand command)
protected boolean	shouldInvokeRemoteTxCommand(TxInvocationContext ctx)
protected static boolean	shouldTotalOrderRollbackBeInvokedRemotely(TxInvocationContext ctx)
protected Map	totalOrderPrepare(Collection recipients, PrepareCommand prepareCommand, TimeoutValidationResponseFilter responseFilter)
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.base.CommandInterceptor

getLockAcquisitionTimeout, getLog, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext

Field Detail

rpcManager

protected RpcManager rpcManager

defaultSynchronous

protected boolean defaultSynchronous

Constructor Detail

BaseRpcInterceptor

public BaseRpcInterceptor()

Method Detail

inject

public void inject(RpcManager rpcManager,
          StateConsumer stateConsumer)

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 final Map totalOrderPrepare(Collection recipients,
                    PrepareCommand prepareCommand,
                    TimeoutValidationResponseFilter responseFilter)

isSyncCommitPhase

protected final boolean isSyncCommitPhase()

getSelfDeliverFilter

protected final TimeoutValidationResponseFilter getSelfDeliverFilter()