org.jboss.cache.interceptors
Class BaseRpcInterceptor

java.lang.Object
  org.jboss.cache.interceptors.Interceptor
      org.jboss.cache.interceptors.BaseRpcInterceptor

All Implemented Interfaces:

InterceptorMBean

Direct Known Subclasses:

DataGravitatorInterceptor, InvalidationInterceptor, OptimisticReplicationInterceptor, ReplicationInterceptor

public abstract class BaseRpcInterceptor
extends Interceptor

Acts as a base for all RPC calls - subclassed by ReplicationInterceptor and OptimisticReplicationInterceptor.

Author:

Manik Surtani (manik@jboss.org)

Field Summary

Fields inherited from class org.jboss.cache.interceptors.Interceptor

cache, configuration, last, log, next

Constructor Summary

BaseRpcInterceptor()

Method Summary

protected void	checkResponses(java.util.List rsps) Checks whether any of the responses are exceptions.
protected boolean	containsModifications(InvocationContext ctx)
protected void	putCallOnAsyncReplicationQueue(MethodCall call)
protected void	replicateCall(java.util.List<org.jgroups.Address> recipients, MethodCall call, boolean sync)
protected void	replicateCall(MethodCall call, boolean sync)
void	setCache(CacheSPI cache)

Methods inherited from class org.jboss.cache.interceptors.Interceptor

dumpStatistics, getLast, getNext, getStatisticsEnabled, invoke, isActive, isOnePhaseCommitPrepareMehod, isPreparing, isValid, resetStatistics, setLast, setNext, setStatisticsEnabled, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseRpcInterceptor

public BaseRpcInterceptor()

Method Detail

setCache

public void setCache(CacheSPI cache)

Overrides:

setCache in class Interceptor

checkResponses

protected void checkResponses(java.util.List rsps)
                       throws java.lang.Throwable

Checks whether any of the responses are exceptions. If yes, re-throws them (as exceptions or runtime exceptions).

Parameters:

rsps -

Throws:

java.lang.Throwable

replicateCall

protected void replicateCall(MethodCall call,
                             boolean sync)
                      throws java.lang.Throwable

Throws:

java.lang.Throwable

replicateCall

protected void replicateCall(java.util.List<org.jgroups.Address> recipients,
                             MethodCall call,
                             boolean sync)
                      throws java.lang.Throwable

Throws:

java.lang.Throwable

putCallOnAsyncReplicationQueue

protected void putCallOnAsyncReplicationQueue(MethodCall call)

containsModifications

protected boolean containsModifications(InvocationContext ctx)