org.jboss.cache.interceptors
Class OptimisticReplicationInterceptor

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

All Implemented Interfaces:

InterceptorMBean

public class OptimisticReplicationInterceptor
extends BaseRpcInterceptor

Replication interceptor for the optimistically locked interceptor chain

Author:

Manik Surtani (manik@jboss.org), Steve Woodcock (stevew@jofti.com)

Constructor Summary

OptimisticReplicationInterceptor()

Method Summary

protected void	broadcastCommit(org.jgroups.blocks.MethodCall methodCall, GlobalTransaction gtx)
protected java.lang.Object	broadcastPrepare(org.jgroups.blocks.MethodCall methodCall, GlobalTransaction gtx)
protected void	broadcastRollback(org.jgroups.blocks.MethodCall methodCall, GlobalTransaction gtx)
java.lang.Object	invoke(org.jgroups.blocks.MethodCall m)
void	setCache(TreeCache cache)

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

checkResponses, containsModifications, putCallOnAsyncReplicationQueue, replicateCall

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

dumpStatistics, getInvocationContext, getNext, getStatisticsEnabled, isActive, 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

OptimisticReplicationInterceptor

public OptimisticReplicationInterceptor()

Method Detail

setCache

public void setCache(TreeCache cache)

Overrides:

setCache in class BaseRpcInterceptor

invoke

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

Overrides:

invoke in class Interceptor

Throws:

java.lang.Throwable

broadcastPrepare

protected java.lang.Object broadcastPrepare(org.jgroups.blocks.MethodCall methodCall,
                                            GlobalTransaction gtx)
                                     throws java.lang.Throwable

Throws:

java.lang.Throwable

broadcastCommit

protected void broadcastCommit(org.jgroups.blocks.MethodCall methodCall,
                               GlobalTransaction gtx)
                        throws java.lang.Throwable

Throws:

java.lang.Throwable

broadcastRollback

protected void broadcastRollback(org.jgroups.blocks.MethodCall methodCall,
                                 GlobalTransaction gtx)
                          throws java.lang.Throwable

Throws:

java.lang.Throwable