org.infinispan.interceptors.base
Class BaseRpcInterceptor

java.lang.Object
  org.infinispan.commands.AbstractVisitor
      org.infinispan.interceptors.base.CommandInterceptor
          org.infinispan.interceptors.base.BaseRpcInterceptor

All Implemented Interfaces:

Visitor

Direct Known Subclasses:

DistributionInterceptor, InvalidationInterceptor, ReplicationInterceptor

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

protected boolean	defaultSynchronous
protected RpcManager	rpcManager

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

configuration, log, trace

Constructor Summary

BaseRpcInterceptor()

Method Summary

void	init()
void	init(RpcManager rpcManager)
protected boolean	isLocalModeForced(InvocationContext ctx)
protected boolean	isSynchronous(InvocationContext ctx)
protected boolean	shouldInvokeRemoteTxCommand(TxInvocationContext ctx)
Object	visitLockControlCommand(TxInvocationContext ctx, LockControlCommand command)

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

getNext, handleDefault, hasNext, invokeNextInterceptor, setNext

Methods inherited from class org.infinispan.commands.AbstractVisitor

visitClearCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand

Methods inherited from class java.lang.Object

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

Field Detail

rpcManager

protected RpcManager rpcManager

defaultSynchronous

protected boolean defaultSynchronous

Constructor Detail

BaseRpcInterceptor

public BaseRpcInterceptor()

Method Detail

init

public void init(RpcManager rpcManager)

init

public void init()

visitLockControlCommand

public Object visitLockControlCommand(TxInvocationContext ctx,
                                      LockControlCommand command)
                               throws Throwable

Specified by:

visitLockControlCommand in interface Visitor

Overrides:

visitLockControlCommand in class AbstractVisitor

Throws:

Throwable

isSynchronous

protected final boolean isSynchronous(InvocationContext ctx)

isLocalModeForced

protected final boolean isLocalModeForced(InvocationContext ctx)

shouldInvokeRemoteTxCommand

protected final boolean shouldInvokeRemoteTxCommand(TxInvocationContext ctx)