[jbosscache-commits] JBoss Cache SVN: r6240 - core/trunk/src/test/java/org/jboss/cache/factories.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-07-10 07:59:23 -0400 (Thu, 10 Jul 2008)
New Revision: 6240

Modified:
   core/trunk/src/test/java/org/jboss/cache/factories/InterceptorChainFactoryTest.java
Log:
Updated test to consider new interceptors

Modified: core/trunk/src/test/java/org/jboss/cache/factories/InterceptorChainFactoryTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/factories/InterceptorChainFactoryTest.java	2008-07-10 11:59:05 UTC (rev 6239)
+++ core/trunk/src/test/java/org/jboss/cache/factories/InterceptorChainFactoryTest.java	2008-07-10 11:59:23 UTC (rev 6240)
@@ -7,6 +7,7 @@
 import org.jboss.cache.config.CacheLoaderConfig;
 import org.jboss.cache.config.CacheLoaderConfig.IndividualCacheLoaderConfig;
 import static org.jboss.cache.config.Configuration.CacheMode.*;
+import static org.jboss.cache.config.Configuration.NodeLockingScheme.MVCC;
 import static org.jboss.cache.config.Configuration.NodeLockingScheme.OPTIMISTIC;
 import org.jboss.cache.config.EvictionConfig;
 import org.jboss.cache.interceptors.*;
@@ -23,7 +24,7 @@
 import java.util.Iterator;
 import java.util.List;
 
- at Test(groups = {"functional"})
+ at Test(groups = "unit")
 public class InterceptorChainFactoryTest extends InterceptorChainTestBase
 {
    CacheSPI cache = null;
@@ -67,6 +68,27 @@
    }
 
 
+   public void testMvccConfig() throws Exception
+   {
+      cache.getConfiguration().setExposeManagementStatistics(false);
+      cache.getConfiguration().setNodeLockingScheme(MVCC);
+      InterceptorChain chain = getInterceptorChainFactory(cache).buildInterceptorChain();
+      List<CommandInterceptor> list = chain.asList();
+      Iterator<CommandInterceptor> interceptors = list.iterator();
+
+      System.out.println("testMvccConfig interceptors are:\n" + list);
+      assertNotNull(list);
+      assertEquals(5, list.size());
+
+      assertEquals(InvocationContextInterceptor.class, interceptors.next().getClass());
+      assertEquals(TxInterceptor.class, interceptors.next().getClass());
+      assertEquals(NotificationInterceptor.class, interceptors.next().getClass());
+      assertEquals(MVCCLockingInterceptor.class, interceptors.next().getClass());
+      assertEquals(CallInterceptor.class, interceptors.next().getClass());
+
+      assertInterceptorLinkage(list);
+   }
+
    public void testTxConfig() throws Exception
    {
       cache.getConfiguration().setExposeManagementStatistics(false);
@@ -122,13 +144,44 @@
       assertEquals(NotificationInterceptor.class, interceptors.next().getClass());
       assertEquals(ReplicationInterceptor.class, interceptors.next().getClass());
       assertEquals(PessimisticLockInterceptor.class, interceptors.next().getClass());
+      assertEquals(LegacyCacheLoaderInterceptor.class, interceptors.next().getClass());
+      assertEquals(CacheStoreInterceptor.class, interceptors.next().getClass());
+      assertEquals(CallInterceptor.class, interceptors.next().getClass());
+
+      assertInterceptorLinkage(list);
+   }
+
+   public void testSharedCacheLoaderMvccConfig() throws Exception
+   {
+      cache.getConfiguration().setExposeManagementStatistics(false);
+      cache.getConfiguration().setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
+      cache.getConfiguration().setCacheLoaderConfig(getCacheLoaderConfig(false, false));
+      cache.getConfiguration().setCacheMode(REPL_ASYNC);
+      cache.getConfiguration().setNodeLockingScheme(MVCC);
+      cache.getConfiguration().setFetchInMemoryState(false);
+      cache.create();
+      InterceptorChain chain = getInterceptorChainFactory(cache).buildInterceptorChain();
+      List<CommandInterceptor> list = chain.asList();
+      Iterator<CommandInterceptor> interceptors = list.iterator();
+
+      System.out.println("testSharedCacheLoaderConfig interceptors are:\n" + list);
+      assertNotNull(list);
+
+      assertEquals(8, list.size());
+
+      assertEquals(InvocationContextInterceptor.class, interceptors.next().getClass());
+      assertEquals(TxInterceptor.class, interceptors.next().getClass());
+      assertEquals(NotificationInterceptor.class, interceptors.next().getClass());
+      assertEquals(ReplicationInterceptor.class, interceptors.next().getClass());
       assertEquals(CacheLoaderInterceptor.class, interceptors.next().getClass());
+      assertEquals(MVCCLockingInterceptor.class, interceptors.next().getClass());
       assertEquals(CacheStoreInterceptor.class, interceptors.next().getClass());
       assertEquals(CallInterceptor.class, interceptors.next().getClass());
 
       assertInterceptorLinkage(list);
    }
 
+
    public void testUnsharedCacheLoaderConfig() throws Exception
    {
       cache.getConfiguration().setExposeManagementStatistics(false);
@@ -151,7 +204,37 @@
       assertEquals(NotificationInterceptor.class, interceptors.next().getClass());
       assertEquals(ReplicationInterceptor.class, interceptors.next().getClass());
       assertEquals(PessimisticLockInterceptor.class, interceptors.next().getClass());
+      assertEquals(LegacyCacheLoaderInterceptor.class, interceptors.next().getClass());
+      assertEquals(CacheStoreInterceptor.class, interceptors.next().getClass());
+      assertEquals(CallInterceptor.class, interceptors.next().getClass());
+
+      assertInterceptorLinkage(list);
+   }
+
+   public void testUnsharedCacheLoaderMvccConfig() throws Exception
+   {
+      cache.getConfiguration().setExposeManagementStatistics(false);
+      cache.getConfiguration().setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
+      cache.getConfiguration().setCacheLoaderConfig(getCacheLoaderConfig(false, true));
+      cache.getConfiguration().setCacheMode(REPL_ASYNC);
+      cache.getConfiguration().setNodeLockingScheme(MVCC);
+      cache.getConfiguration().setFetchInMemoryState(false);
+      cache.create();
+      InterceptorChain chain = getInterceptorChainFactory(cache).buildInterceptorChain();
+      List<CommandInterceptor> list = chain.asList();
+      Iterator<CommandInterceptor> interceptors = list.iterator();
+
+      System.out.println("testUnsharedCacheLoaderConfig interceptors are:\n" + list);
+      assertNotNull(list);
+
+      assertEquals(8, list.size());
+
+      assertEquals(InvocationContextInterceptor.class, interceptors.next().getClass());
+      assertEquals(TxInterceptor.class, interceptors.next().getClass());
+      assertEquals(NotificationInterceptor.class, interceptors.next().getClass());
+      assertEquals(ReplicationInterceptor.class, interceptors.next().getClass());
       assertEquals(CacheLoaderInterceptor.class, interceptors.next().getClass());
+      assertEquals(MVCCLockingInterceptor.class, interceptors.next().getClass());
       assertEquals(CacheStoreInterceptor.class, interceptors.next().getClass());
       assertEquals(CallInterceptor.class, interceptors.next().getClass());
 
@@ -246,7 +329,7 @@
       assertEquals(InvocationContextInterceptor.class, interceptors.next().getClass());
       assertEquals(OptimisticTxInterceptor.class, interceptors.next().getClass());
       assertEquals(NotificationInterceptor.class, interceptors.next().getClass());
-      assertEquals(CacheLoaderInterceptor.class, interceptors.next().getClass());
+      assertEquals(LegacyCacheLoaderInterceptor.class, interceptors.next().getClass());
       assertEquals(CacheStoreInterceptor.class, interceptors.next().getClass());
       assertEquals(OptimisticLockingInterceptor.class, interceptors.next().getClass());
       assertEquals(OptimisticValidatorInterceptor.class, interceptors.next().getClass());
@@ -272,7 +355,7 @@
       assertEquals(InvocationContextInterceptor.class, interceptors.next().getClass());
       assertEquals(OptimisticTxInterceptor.class, interceptors.next().getClass());
       assertEquals(NotificationInterceptor.class, interceptors.next().getClass());
-      assertEquals(ActivationInterceptor.class, interceptors.next().getClass());
+      assertEquals(LegacyActivationInterceptor.class, interceptors.next().getClass());
       assertEquals(PassivationInterceptor.class, interceptors.next().getClass());
       assertEquals(OptimisticLockingInterceptor.class, interceptors.next().getClass());
       assertEquals(OptimisticValidatorInterceptor.class, interceptors.next().getClass());
@@ -283,6 +366,29 @@
       assertInterceptorLinkage(list);
    }
 
+   public void testPassivationMvccChain() throws Exception
+   {
+      cache.getConfiguration().setExposeManagementStatistics(false);
+      cache.getConfiguration().setNodeLockingScheme(MVCC);
+      cache.getConfiguration().setCacheLoaderConfig(getCacheLoaderConfig(true, false));
+      cache.create();
+      InterceptorChain chain = getInterceptorChainFactory(cache).buildInterceptorChain();
+      List<CommandInterceptor> list = chain.asList();
+      Iterator<CommandInterceptor> interceptors = list.iterator();
+
+      assertEquals(7, list.size());
+
+      assertEquals(InvocationContextInterceptor.class, interceptors.next().getClass());
+      assertEquals(TxInterceptor.class, interceptors.next().getClass());
+      assertEquals(NotificationInterceptor.class, interceptors.next().getClass());
+      assertEquals(ActivationInterceptor.class, interceptors.next().getClass());
+      assertEquals(MVCCLockingInterceptor.class, interceptors.next().getClass());
+      assertEquals(PassivationInterceptor.class, interceptors.next().getClass());
+      assertEquals(CallInterceptor.class, interceptors.next().getClass());
+
+      assertInterceptorLinkage(list);
+   }
+
    public void testInvalidationInterceptorChain() throws Exception
    {
       cache.getConfiguration().setExposeManagementStatistics(false);