org.jboss.cache.interceptors
Class DataGravitatorInterceptor

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

All Implemented Interfaces:

InterceptorMBean

public class DataGravitatorInterceptor
extends BaseRpcInterceptor

The Data Gravitator interceptor intercepts cache misses and attempts t gravitate data from other parts of the cluster.

Only used if Buddy Replication is enabled. Also, the interceptor only kicks in if an Option is passed in to force Data Gravitation for a specific invocation or if autoDataGravitation is set to true when configuring Buddy Replication.

See the JBoss Cache User Guide for more details on configuration options. There is a section dedicated to Buddy Replication in the Replication chapter.

Author:

Manik Surtani (manik@jboss.org)

Constructor Summary

DataGravitatorInterceptor()

Method Summary

java.lang.Object	invoke(org.jgroups.blocks.MethodCall call)
protected void	lock(Fqn fqn)
void	setCache(TreeCache cache)

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

checkResponses, containsModifications, putCallOnAsyncReplicationQueue, replicateCall, replicateCall

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

dumpStatistics, getInvocationContext, getNext, getStatisticsEnabled, isActive, isBuddyGroupOrganisationMethod, isOnePhaseCommitPrepareMehod, isPreparing, isTransactionLifecycleMethod, isValid, resetStatistics, setInvocationContext, setNext, setStatisticsEnabled

Methods inherited from class java.lang.Object

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

Constructor Detail

DataGravitatorInterceptor

public DataGravitatorInterceptor()

Method Detail

setCache

public void setCache(TreeCache cache)

Overrides:

setCache in class BaseRpcInterceptor

invoke

public java.lang.Object invoke(org.jgroups.blocks.MethodCall call)
                        throws java.lang.Throwable

Overrides:

invoke in class Interceptor

Throws:

java.lang.Throwable

lock

protected void lock(Fqn fqn)
             throws java.lang.Throwable

Throws:

java.lang.Throwable