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)

Field Summary

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

cache, configuration, last, next

Constructor Summary

DataGravitatorInterceptor()

Method Summary

java.lang.Object	invoke(InvocationContext ctx)
void	setCache(CacheSPI 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, getLast, getNext, getStatisticsEnabled, 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

DataGravitatorInterceptor

public DataGravitatorInterceptor()

Method Detail

setCache

public void setCache(CacheSPI cache)

Overrides:

setCache in class BaseRpcInterceptor

invoke

public java.lang.Object invoke(InvocationContext ctx)
                        throws java.lang.Throwable

Overrides:

invoke in class Interceptor

Throws:

java.lang.Throwable