|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.cache.interceptors.Interceptor org.jboss.cache.interceptors.MethodDispacherInterceptor org.jboss.cache.interceptors.BaseRpcInterceptor org.jboss.cache.interceptors.ReplicationInterceptor
public class ReplicationInterceptor
Takes care of replicating modifications to other nodes in a cluster. Also listens for prepare(), commit() and rollback() messages which are received 'side-ways' (see docs/design/Refactoring.txt).
Field Summary |
---|
Fields inherited from class org.jboss.cache.interceptors.BaseRpcInterceptor |
---|
defaultSynchronous |
Fields inherited from class org.jboss.cache.interceptors.Interceptor |
---|
cache, configuration, last, log, next, trace |
Constructor Summary | |
---|---|
ReplicationInterceptor()
|
Methods inherited from class org.jboss.cache.interceptors.BaseRpcInterceptor |
---|
containsModifications, checkResponses, isSynchronous, isTransactionalAndLocal, putCallOnAsyncReplicationQueue, replicateCall, replicateCall, replicateCall, replicateCall, setCache, skipReplicationOfTransactionMethod |
Methods inherited from class org.jboss.cache.interceptors.Interceptor |
---|
assertTransactionValid, dumpStatistics, getLast, getNext, getStatisticsEnabled, initLogger, isActive, isPreparing, isValid, nextInterceptor, peekNode, resetStatistics, setLast, setNext, setStatisticsEnabled, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public ReplicationInterceptor()
Method Detail |
---|
protected boolean skipMethodCall(InvocationContext ctx)
MethodDispacherInterceptor
skipMethodCall
in class MethodDispacherInterceptor
protected Object handleCommitMethod(InvocationContext ctx, GlobalTransaction gtx) throws Throwable
MethodDispacherInterceptor
CacheImpl.commit(org.jboss.cache.transaction.GlobalTransaction)
handleCommitMethod
in class MethodDispacherInterceptor
Throwable
protected Object handlePrepareMethod(InvocationContext ctx, GlobalTransaction gtx, List modification, org.jgroups.Address coordinator, boolean onePhaseCommit) throws Throwable
MethodDispacherInterceptor
CacheImpl.prepare(org.jboss.cache.transaction.GlobalTransaction, java.util.List, org.jgroups.Address, boolean)
handlePrepareMethod
in class MethodDispacherInterceptor
Throwable
protected Object handleRollbackMethod(InvocationContext ctx, GlobalTransaction gtx) throws Throwable
MethodDispacherInterceptor
CacheImpl.rollback(org.jboss.cache.transaction.GlobalTransaction)
handleRollbackMethod
in class MethodDispacherInterceptor
Throwable
protected Object handlePutForExternalReadMethod(InvocationContext ctx, GlobalTransaction gtx, Fqn fqn, Object key, Object value) throws Throwable
MethodDispacherInterceptor
CacheImpl._putForExternalRead(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, Object, Object)
handlePutForExternalReadMethod
in class MethodDispacherInterceptor
Throwable
protected Object handlePutDataMethod(InvocationContext ctx, GlobalTransaction tx, Fqn fqn, Map data, boolean createUndoOps) throws Throwable
MethodDispacherInterceptor
CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, String, java.util.Map, boolean)
handlePutDataMethod
in class MethodDispacherInterceptor
Throwable
protected Object handlePutDataEraseMethod(InvocationContext ctx, GlobalTransaction gt, Fqn fqn, Map newData, boolean createUndoOps, boolean eraseContents) throws Throwable
MethodDispacherInterceptor
CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, java.util.Map, boolean, boolean)
handlePutDataEraseMethod
in class MethodDispacherInterceptor
Throwable
protected Object handlePutKeyValueVersionedMethod(InvocationContext ctx, GlobalTransaction gtx, Fqn fqn, Object key, Object value, boolean createUndoOps, DataVersion dv) throws Throwable
MethodDispacherInterceptor
CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, Object, Object, boolean, org.jboss.cache.optimistic.DataVersion)
handlePutKeyValueVersionedMethod
in class MethodDispacherInterceptor
Throwable
protected Object handlePutDataEraseVersionedMethod(InvocationContext ctx, GlobalTransaction gtx, Fqn fqn, Map data, boolean createUndoOps, boolean eraseContent, DataVersion dv) throws Throwable
MethodDispacherInterceptor
CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, java.util.Map, boolean, boolean, org.jboss.cache.optimistic.DataVersion)
handlePutDataEraseVersionedMethod
in class MethodDispacherInterceptor
Throwable
protected Object handlePutDataVersionedMethod(InvocationContext ctx, GlobalTransaction globalTransaction, Fqn fqn, Map map, Boolean createUndoOps, DataVersion dataVersion) throws Throwable
MethodDispacherInterceptor
CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, java.util.Map, boolean, org.jboss.cache.optimistic.DataVersion)
handlePutDataVersionedMethod
in class MethodDispacherInterceptor
Throwable
protected Object handlePutKeyValueMethod(InvocationContext ctx, GlobalTransaction gtx, Fqn fqn, Object key, Object value, boolean createUndoOps) throws Throwable
MethodDispacherInterceptor
CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, String, Object, Object, boolean)
handlePutKeyValueMethod
in class MethodDispacherInterceptor
Throwable
protected Object handlePutForExternalReadVersionedMethod(InvocationContext ctx, GlobalTransaction gtx, Fqn fqn, Object key, Object value, DataVersion dv) throws Throwable
MethodDispacherInterceptor
CacheImpl._putForExternalRead(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, Object, Object, org.jboss.cache.optimistic.DataVersion)
handlePutForExternalReadVersionedMethod
in class MethodDispacherInterceptor
Throwable
protected Object handleRemoveNodeMethod(InvocationContext ctx, GlobalTransaction tx, Fqn fqn, boolean createUndoOps) throws Throwable
MethodDispacherInterceptor
CacheImpl._remove(org.jboss.cache.transaction.GlobalTransaction, String, boolean)
handleRemoveNodeMethod
in class MethodDispacherInterceptor
Throwable
protected Object handleRemoveKeyMethod(InvocationContext ctx, GlobalTransaction tx, Fqn fqn, Object key, boolean createUndoOps) throws Throwable
MethodDispacherInterceptor
CacheImpl._remove(org.jboss.cache.transaction.GlobalTransaction, String, Object, boolean)
handleRemoveKeyMethod
in class MethodDispacherInterceptor
Throwable
protected Object handleRemoveDataMethod(InvocationContext ctx, GlobalTransaction tx, Fqn fqn, boolean createUndoOps) throws Throwable
MethodDispacherInterceptor
CacheImpl._removeData(org.jboss.cache.transaction.GlobalTransaction, Fqn, boolean)
handleRemoveDataMethod
in class MethodDispacherInterceptor
Throwable
protected Object handleDataGravitationCleanupMethod(InvocationContext ctx, Fqn primary, Fqn backup) throws Throwable
MethodDispacherInterceptor
RemoteCacheInvocationDelegate.dataGravitationCleanup(org.jboss.cache.Fqn, org.jboss.cache.Fqn)
handleDataGravitationCleanupMethod
in class MethodDispacherInterceptor
Throwable
protected Object handleMoveMethod(InvocationContext ctx, Fqn from, Fqn to) throws Throwable
MethodDispacherInterceptor
CacheImpl._move(org.jboss.cache.Fqn, org.jboss.cache.Fqn)
handleMoveMethod
in class MethodDispacherInterceptor
Throwable
protected Object handleRemoveNodeVersionedMethod(InvocationContext ctx, GlobalTransaction gtx, Fqn fqn, boolean createUndoOps, DataVersion dv) throws Throwable
MethodDispacherInterceptor
CacheImpl._remove(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, boolean, org.jboss.cache.optimistic.DataVersion)
handleRemoveNodeVersionedMethod
in class MethodDispacherInterceptor
Throwable
protected Object handleRemoveKeyVersionedMethod(InvocationContext ctx, GlobalTransaction gtx, Fqn fqn, Object key, boolean createUndoOps, DataVersion dv) throws Throwable
MethodDispacherInterceptor
CacheImpl._remove(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, Object, boolean, org.jboss.cache.optimistic.DataVersion)
handleRemoveKeyVersionedMethod
in class MethodDispacherInterceptor
Throwable
protected Object handleRemoveDataVersionedMethod(InvocationContext ctx, GlobalTransaction gtx, Fqn fqn, boolean createUndoOps, DataVersion dv) throws Throwable
MethodDispacherInterceptor
CacheImpl._removeData(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, boolean, org.jboss.cache.optimistic.DataVersion)
handleRemoveDataVersionedMethod
in class MethodDispacherInterceptor
Throwable
protected void runPreparePhase(MethodCall prepareMethod, GlobalTransaction gtx, InvocationContext ctx) throws Throwable
Exception
Throwable
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |