[jbosscache-commits] JBoss Cache SVN: r6871 - core/branches/flat/src/main/java/org/jboss/starobrno/interceptors/base.

Author: manik.surtani(a)jboss.com Date: 2008-10-08 09:04:49 -0400 (Wed, 08 Oct 2008) New Revision: 6871 Modified: core/branches/flat/src/main/java/org/jboss/starobrno/interceptors/base/PrePostProcessingCommandInterceptor.java core/branches/flat/src/main/java/org/jboss/starobrno/interceptors/base/SkipCheckChainedInterceptor.java Log: Fixed stuff Modified: core/branches/flat/src/main/java/org/jboss/starobrno/interceptors/base/PrePostProcessingCommandInterceptor.java =================================================================== --- core/branches/flat/src/main/java/org/jboss/starobrno/interceptors/base/PrePostProcessingCommandInterceptor.java 2008-10-08 12:42:02 UTC (rev 6870) +++ core/branches/flat/src/main/java/org/jboss/starobrno/interceptors/base/PrePostProcessingCommandInterceptor.java 2008-10-08 13:04:49 UTC (rev 6871) @@ -21,30 +21,20 @@ */ package org.jboss.starobrno.interceptors.base; -import org.jboss.cache.InvocationContext; -import org.jboss.cache.interceptors.base.CommandInterceptor; -import org.jboss.cache.commands.VisitableCommand; -import org.jboss.cache.commands.legacy.write.CreateNodeCommand; -import org.jboss.cache.commands.read.ExistsCommand; -import org.jboss.cache.commands.read.GetChildrenNamesCommand; -import org.jboss.cache.commands.read.GetDataMapCommand; -import org.jboss.cache.commands.read.GetKeyValueCommand; -import org.jboss.cache.commands.read.GetKeysCommand; -import org.jboss.cache.commands.read.GetNodeCommand; -import org.jboss.cache.commands.read.GravitateDataCommand; -import org.jboss.cache.commands.tx.CommitCommand; -import org.jboss.cache.commands.tx.OptimisticPrepareCommand; -import org.jboss.cache.commands.tx.PrepareCommand; -import org.jboss.cache.commands.tx.RollbackCommand; -import org.jboss.cache.commands.write.ClearDataCommand; -import org.jboss.cache.commands.write.EvictCommand; -import org.jboss.cache.commands.write.InvalidateCommand; -import org.jboss.cache.commands.write.MoveCommand; -import org.jboss.cache.commands.write.PutDataMapCommand; -import org.jboss.cache.commands.write.PutForExternalReadCommand; -import org.jboss.cache.commands.write.PutKeyValueCommand; -import org.jboss.cache.commands.write.RemoveKeyCommand; -import org.jboss.cache.commands.write.RemoveNodeCommand; +import org.jboss.starobrno.commands.VisitableCommand; +import org.jboss.starobrno.commands.read.GetKeyValueCommand; +import org.jboss.starobrno.commands.read.GravitateDataCommand; +import org.jboss.starobrno.commands.read.SizeCommand; +import org.jboss.starobrno.commands.tx.CommitCommand; +import org.jboss.starobrno.commands.tx.PrepareCommand; +import org.jboss.starobrno.commands.tx.RollbackCommand; +import org.jboss.starobrno.commands.write.ClearCommand; +import org.jboss.starobrno.commands.write.EvictCommand; +import org.jboss.starobrno.commands.write.PutKeyValueCommand; +import org.jboss.starobrno.commands.write.PutMapCommand; +import org.jboss.starobrno.commands.write.RemoveCommand; +import org.jboss.starobrno.commands.write.ReplaceCommand; +import org.jboss.starobrno.context.InvocationContext; /** * This interceptor adds pre and post processing to each <tt>visitXXX()</tt> method. @@ -64,11 +54,11 @@ public abstract class PrePostProcessingCommandInterceptor extends CommandInterceptor { @Override - public final Object visitPutDataMapCommand(InvocationContext ctx, PutDataMapCommand command) throws Throwable + public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handlePutDataMapCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handlePutKeyValueCommand(ctx, command) : null; } finally { @@ -76,55 +66,17 @@ } } - protected Object handlePutDataMapCommand(InvocationContext ctx, PutDataMapCommand command) throws Throwable - { - return handleDefault(ctx, command); - } - - @Override - public final Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable - { - try - { - return doBeforeCall(ctx, command) ? handlePutKeyValueCommand(ctx, command) : null; - } - finally - { - doAfterCall(ctx, command); - } - } - - @Override - public final Object visitPutForExternalReadCommand(InvocationContext ctx, PutForExternalReadCommand command) throws Throwable - { - try - { - return doBeforeCall(ctx, command) ? handlePutForExternalReadCommand(ctx, command) : null; - } - finally - { - doAfterCall(ctx, command); - } - } - - protected Object handlePutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable { return handleDefault(ctx, command); } - protected Object handlePutForExternalReadCommand(InvocationContext ctx, PutForExternalReadCommand command) throws Throwable - { - return handleDefault(ctx, command); - } - - @Override - public final Object visitRemoveNodeCommand(InvocationContext ctx, RemoveNodeCommand command) throws Throwable + public Object visitRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleRemoveNodeCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handleRemoveCommand(ctx, command) : null; } finally { @@ -132,17 +84,17 @@ } } - protected Object handleRemoveNodeCommand(InvocationContext ctx, RemoveNodeCommand command) throws Throwable + protected Object handleRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable { return handleDefault(ctx, command); } @Override - public final Object visitCreateNodeCommand(InvocationContext ctx, CreateNodeCommand command) throws Throwable + public Object visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleCreateNodeCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handleReplaceCommand(ctx, command) : null; } finally { @@ -150,22 +102,17 @@ } } - /** - * @deprecated in 3.0. Will be removed when Optimistic and Pessimistic locking is removed. - */ - @Deprecated - protected Object handleCreateNodeCommand(InvocationContext ctx, CreateNodeCommand command) throws Throwable + protected Object handleReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable { return handleDefault(ctx, command); } - @Override - public final Object visitClearDataCommand(InvocationContext ctx, ClearDataCommand command) throws Throwable + public Object visitClearCommand(InvocationContext ctx, ClearCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleClearDataCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handleClearCommand(ctx, command) : null; } finally { @@ -173,17 +120,17 @@ } } - protected Object handleClearDataCommand(InvocationContext ctx, ClearDataCommand command) throws Throwable + protected Object handleClearCommand(InvocationContext ctx, ClearCommand command) throws Throwable { return handleDefault(ctx, command); } @Override - public final Object visitEvictFqnCommand(InvocationContext ctx, EvictCommand command) throws Throwable + public Object visitPutMapCommand(InvocationContext ctx, PutMapCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleEvictFqnCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handlePutMapCommand(ctx, command) : null; } finally { @@ -191,17 +138,17 @@ } } - protected Object handleEvictFqnCommand(InvocationContext ctx, EvictCommand command) throws Throwable + protected Object handlePutMapCommand(InvocationContext ctx, PutMapCommand command) throws Throwable { return handleDefault(ctx, command); } @Override - public final Object visitInvalidateCommand(InvocationContext ctx, InvalidateCommand command) throws Throwable + public Object visitEvictCommand(InvocationContext ctx, EvictCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleInvalidateCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handleEvictCommand(ctx, command) : null; } finally { @@ -209,35 +156,19 @@ } } - protected Object handleInvalidateCommand(InvocationContext ctx, InvalidateCommand command) throws Throwable + protected Object handleEvictCommand(InvocationContext ctx, EvictCommand command) throws Throwable { return handleDefault(ctx, command); } - @Override - public final Object visitRemoveKeyCommand(InvocationContext ctx, RemoveKeyCommand command) throws Throwable - { - try - { - return doBeforeCall(ctx, command) ? handleRemoveKeyCommand(ctx, command) : null; - } - finally - { - doAfterCall(ctx, command); - } - } + // read commands - protected Object handleRemoveKeyCommand(InvocationContext ctx, RemoveKeyCommand command) throws Throwable - { - return handleDefault(ctx, command); - } - @Override - public final Object visitGetDataMapCommand(InvocationContext ctx, GetDataMapCommand command) throws Throwable + public Object visitSizeCommand(InvocationContext ctx, SizeCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleGetDataMapCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handleSizeCommand(ctx, command) : null; } finally { @@ -245,17 +176,17 @@ } } - protected Object handleGetDataMapCommand(InvocationContext ctx, GetDataMapCommand command) throws Throwable + protected Object handleSizeCommand(InvocationContext ctx, SizeCommand command) throws Throwable { return handleDefault(ctx, command); } @Override - public final Object visitExistsNodeCommand(InvocationContext ctx, ExistsCommand command) throws Throwable + public Object visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleExistsNodeCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handleGetKeyValueCommand(ctx, command) : null; } finally { @@ -263,35 +194,17 @@ } } - protected Object handleExistsNodeCommand(InvocationContext ctx, ExistsCommand command) throws Throwable - { - return handleDefault(ctx, command); - } - - @Override - public final Object visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable - { - try - { - return doBeforeCall(ctx, command) ? handleGetKeyValueCommand(ctx, command) : null; - } - finally - { - doAfterCall(ctx, command); - } - } - protected Object handleGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable { return handleDefault(ctx, command); } @Override - public final Object visitGetNodeCommand(InvocationContext ctx, GetNodeCommand command) throws Throwable + public Object visitGravitateDataCommand(InvocationContext ctx, GravitateDataCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleGetNodeCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handleGravitateDataCommand(ctx, command) : null; } finally { @@ -299,35 +212,19 @@ } } - protected Object handleGetNodeCommand(InvocationContext ctx, GetNodeCommand command) throws Throwable + protected Object handleGravitateDataCommand(InvocationContext ctx, GravitateDataCommand command) throws Throwable { return handleDefault(ctx, command); } - @Override - public final Object visitGetKeysCommand(InvocationContext ctx, GetKeysCommand command) throws Throwable - { - try - { - return doBeforeCall(ctx, command) ? handleGetKeysCommand(ctx, command) : null; - } - finally - { - doAfterCall(ctx, command); - } - } + // tx commands - protected Object handleGetKeysCommand(InvocationContext ctx, GetKeysCommand command) throws Throwable - { - return handleDefault(ctx, command); - } - @Override - public final Object visitGetChildrenNamesCommand(InvocationContext ctx, GetChildrenNamesCommand command) throws Throwable + public Object visitPrepareCommand(InvocationContext ctx, PrepareCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleGetChildrenNamesCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handlePrepareCommand(ctx, command) : null; } finally { @@ -335,71 +232,17 @@ } } - protected Object handleGetChildrenNamesCommand(InvocationContext ctx, GetChildrenNamesCommand command) throws Throwable - { - return handleDefault(ctx, command); - } - - @Override - public final Object visitMoveCommand(InvocationContext ctx, MoveCommand command) throws Throwable - { - try - { - return doBeforeCall(ctx, command) ? handleMoveCommand(ctx, command) : null; - } - finally - { - doAfterCall(ctx, command); - } - } - - protected Object handleMoveCommand(InvocationContext ctx, MoveCommand command) throws Throwable - { - return handleDefault(ctx, command); - } - - @Override - public final Object visitGravitateDataCommand(InvocationContext ctx, GravitateDataCommand command) throws Throwable - { - try - { - return doBeforeCall(ctx, command) ? handleGravitateDataCommand(ctx, command) : null; - } - finally - { - doAfterCall(ctx, command); - } - } - - protected Object handleGravitateDataCommand(InvocationContext ctx, GravitateDataCommand command) throws Throwable - { - return handleDefault(ctx, command); - } - - @Override - public final Object visitPrepareCommand(InvocationContext ctx, PrepareCommand command) throws Throwable - { - try - { - return doBeforeCall(ctx, command) ? handlePrepareCommand(ctx, command) : null; - } - finally - { - doAfterCall(ctx, command); - } - } - protected Object handlePrepareCommand(InvocationContext ctx, PrepareCommand command) throws Throwable { return handleDefault(ctx, command); } @Override - public final Object visitRollbackCommand(InvocationContext ctx, RollbackCommand command) throws Throwable + public Object visitRollbackCommand(InvocationContext ctx, RollbackCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleRollbackCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handleRollbackCommand(ctx, command) : null; } finally { @@ -413,11 +256,11 @@ } @Override - public final Object visitCommitCommand(InvocationContext ctx, CommitCommand command) throws Throwable + public Object visitCommitCommand(InvocationContext ctx, CommitCommand command) throws Throwable { try { - return doBeforeCall(ctx, command) ? handleCommitCommand(ctx, command) : null; + return (doBeforeCall(ctx, command)) ? handleCommitCommand(ctx, command) : null; } finally { @@ -430,24 +273,6 @@ return handleDefault(ctx, command); } - @Override - public final Object visitOptimisticPrepareCommand(InvocationContext ctx, OptimisticPrepareCommand command) throws Throwable - { - try - { - return doBeforeCall(ctx, command) ? handleOptimisticPrepareCommand(ctx, command) : null; - } - finally - { - doAfterCall(ctx, command); - } - } - - protected Object handleOptimisticPrepareCommand(InvocationContext ctx, OptimisticPrepareCommand command) throws Throwable - { - return handleDefault(ctx, command); - } - /** * Callback that is invoked after every handleXXX() method defined above. * Modified: core/branches/flat/src/main/java/org/jboss/starobrno/interceptors/base/SkipCheckChainedInterceptor.java =================================================================== --- core/branches/flat/src/main/java/org/jboss/starobrno/interceptors/base/SkipCheckChainedInterceptor.java 2008-10-08 12:42:02 UTC (rev 6870) +++ core/branches/flat/src/main/java/org/jboss/starobrno/interceptors/base/SkipCheckChainedInterceptor.java 2008-10-08 13:04:49 UTC (rev 6871) @@ -21,29 +21,8 @@ */ package org.jboss.starobrno.interceptors.base; -import org.jboss.cache.InvocationContext; -import org.jboss.cache.interceptors.base.CommandInterceptor; -import org.jboss.cache.commands.VisitableCommand; -import org.jboss.cache.commands.read.ExistsCommand; -import org.jboss.cache.commands.read.GetChildrenNamesCommand; -import org.jboss.cache.commands.read.GetDataMapCommand; -import org.jboss.cache.commands.read.GetKeyValueCommand; -import org.jboss.cache.commands.read.GetKeysCommand; -import org.jboss.cache.commands.read.GetNodeCommand; -import org.jboss.cache.commands.read.GravitateDataCommand; -import org.jboss.cache.commands.tx.CommitCommand; -import org.jboss.cache.commands.tx.OptimisticPrepareCommand; -import org.jboss.cache.commands.tx.PrepareCommand; -import org.jboss.cache.commands.tx.RollbackCommand; -import org.jboss.cache.commands.write.ClearDataCommand; -import org.jboss.cache.commands.write.EvictCommand; -import org.jboss.cache.commands.write.InvalidateCommand; -import org.jboss.cache.commands.write.MoveCommand; -import org.jboss.cache.commands.write.PutDataMapCommand; -import org.jboss.cache.commands.write.PutForExternalReadCommand; -import org.jboss.cache.commands.write.PutKeyValueCommand; -import org.jboss.cache.commands.write.RemoveKeyCommand; -import org.jboss.cache.commands.write.RemoveNodeCommand; +import org.jboss.starobrno.commands.VisitableCommand; +import org.jboss.starobrno.context.InvocationContext; /** * This interceptor will call {@link #skipInterception(org.jboss.cache.InvocationContext ,org.jboss.cache.commands.VisitableCommand)} before invoking each visit method @@ -61,307 +40,10 @@ */ public abstract class SkipCheckChainedInterceptor extends CommandInterceptor { - @Override - public final Object visitPutDataMapCommand(InvocationContext ctx, PutDataMapCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handlePutDataMapCommand(ctx, command); - } - protected Object handlePutDataMapCommand(InvocationContext ctx, PutDataMapCommand command) throws Throwable - { - return handleAll(ctx, command); - } + // TODO!!! @Override - public final Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handlePutKeyValueCommand(ctx, command); - } - - @Override - public final Object visitPutForExternalReadCommand(InvocationContext ctx, PutForExternalReadCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handlePutForExternalReadCommand(ctx, command); - } - - protected Object handlePutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - protected Object handlePutForExternalReadCommand(InvocationContext ctx, PutForExternalReadCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitRemoveNodeCommand(InvocationContext ctx, RemoveNodeCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleRemoveNodeCommand(ctx, command); - } - - protected Object handleRemoveNodeCommand(InvocationContext ctx, RemoveNodeCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitClearDataCommand(InvocationContext ctx, ClearDataCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleRemoveDataCommand(ctx, command); - } - - protected Object handleRemoveDataCommand(InvocationContext ctx, ClearDataCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitEvictFqnCommand(InvocationContext ctx, EvictCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleEvictFqnCommand(ctx, command); - } - - protected Object handleEvictFqnCommand(InvocationContext ctx, EvictCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitInvalidateCommand(InvocationContext ctx, InvalidateCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleInvalidateCommand(ctx, command); - } - - protected Object handleInvalidateCommand(InvocationContext ctx, InvalidateCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitRemoveKeyCommand(InvocationContext ctx, RemoveKeyCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleRemoveKeyCommand(ctx, command); - } - - protected Object handleRemoveKeyCommand(InvocationContext ctx, RemoveKeyCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitGetDataMapCommand(InvocationContext ctx, GetDataMapCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleGetDataMapCommand(ctx, command); - } - - protected Object handleGetDataMapCommand(InvocationContext ctx, GetDataMapCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitExistsNodeCommand(InvocationContext ctx, ExistsCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleExistsNodeCommand(ctx, command); - } - - protected Object handleExistsNodeCommand(InvocationContext ctx, ExistsCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleGetKeyValueCommand(ctx, command); - } - - protected Object handleGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitGetNodeCommand(InvocationContext ctx, GetNodeCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleGetNodeCommand(ctx, command); - } - - protected Object handleGetNodeCommand(InvocationContext ctx, GetNodeCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitGetKeysCommand(InvocationContext ctx, GetKeysCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleGetKeysCommand(ctx, command); - } - - protected Object handleGetKeysCommand(InvocationContext ctx, GetKeysCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitGetChildrenNamesCommand(InvocationContext ctx, GetChildrenNamesCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleGetChildrenNamesCommand(ctx, command); - } - - protected Object handleGetChildrenNamesCommand(InvocationContext ctx, GetChildrenNamesCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitMoveCommand(InvocationContext ctx, MoveCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleMoveCommand(ctx, command); - } - - protected Object handleMoveCommand(InvocationContext ctx, MoveCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitGravitateDataCommand(InvocationContext ctx, GravitateDataCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleGravitateDataCommand(ctx, command); - } - - protected Object handleGravitateDataCommand(InvocationContext ctx, GravitateDataCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitPrepareCommand(InvocationContext ctx, PrepareCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handlePrepareCommand(ctx, command); - } - - protected Object handlePrepareCommand(InvocationContext ctx, PrepareCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitRollbackCommand(InvocationContext ctx, RollbackCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleRollbackCommand(ctx, command); - } - - protected Object handleRollbackCommand(InvocationContext ctx, RollbackCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitCommitCommand(InvocationContext ctx, CommitCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleCommitCommand(ctx, command); - } - - protected Object handleCommitCommand(InvocationContext ctx, CommitCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override - public final Object visitOptimisticPrepareCommand(InvocationContext ctx, OptimisticPrepareCommand command) throws Throwable - { - if (skipInterception(ctx, command)) - { - return invokeNextInterceptor(ctx, command); - } - return handleOptimisticPrepareCommand(ctx, command); - } - - protected Object handleOptimisticPrepareCommand(InvocationContext ctx, OptimisticPrepareCommand command) throws Throwable - { - return handleAll(ctx, command); - } - - @Override public final Object handleDefault(InvocationContext ctx, VisitableCommand command) throws Throwable { if (skipInterception(ctx, command))