[jbosscache-commits] JBoss Cache SVN: r7852 - in core/branches/flat/src: test/java/org/horizon/loader and 1 other directory.

[jbosscache-commits at lists.jboss.org]

Author: adriancole
Date: 2009-03-04 19:22:03 -0500 (Wed, 04 Mar 2009)
New Revision: 7852

Added:
   core/branches/flat/src/test/java/org/horizon/loader/AbstractCacheStoreConfigTest.java
   core/branches/flat/src/test/java/org/horizon/loader/AbstractCacheStoreTest.java
Modified:
   core/branches/flat/src/main/java/org/horizon/loader/AbstractCacheStoreConfig.java
Log:
added javadoc and tests for base classes

Modified: core/branches/flat/src/main/java/org/horizon/loader/AbstractCacheStoreConfig.java
===================================================================
--- core/branches/flat/src/main/java/org/horizon/loader/AbstractCacheStoreConfig.java	2009-03-04 18:04:58 UTC (rev 7851)
+++ core/branches/flat/src/main/java/org/horizon/loader/AbstractCacheStoreConfig.java	2009-03-05 00:22:03 UTC (rev 7852)
@@ -1,9 +1,17 @@
 package org.horizon.loader;
 
 /**
- * Configuration for {@link AbstractCacheStore}.
+ * Configures {@link AbstractCacheStore}.  This allows you to tune a number of characteristics of the {@link
+ * AbstractCacheStore}.
+ * <p/>
+ * <ul> <li><tt>purgeSynchronously</tt> - whether {@link org.horizon.loader.CacheStore#purgeExpired()} calls happen
+ * synchronously or not.  By default, this is set to <tt>false</tt>.</li>
+ * <p/>
+ * </ul>
  *
  * @author Mircea.Markus at jboss.com
+ * @version $Id$
+ * @since 1.0
  */
 public class AbstractCacheStoreConfig extends AbstractCacheLoaderConfig {
 

Added: core/branches/flat/src/test/java/org/horizon/loader/AbstractCacheStoreConfigTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/loader/AbstractCacheStoreConfigTest.java	                        (rev 0)
+++ core/branches/flat/src/test/java/org/horizon/loader/AbstractCacheStoreConfigTest.java	2009-03-05 00:22:03 UTC (rev 7852)
@@ -0,0 +1,38 @@
+package org.horizon.loader;
+
+import org.testng.annotations.AfterMethod;
+import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.Test;
+
+/**
+ * Unit tests that cover {@link  AbstractCacheStoreConfig }
+ *
+ * @author Adrian Cole
+ * @version $Id: $
+ * @since 1.0
+ */
+ at Test(groups = "unit", enabled = true, testName = "loader.bdbje.AbstractCacheStoreConfig")
+public class AbstractCacheStoreConfigTest {
+   private AbstractCacheStoreConfig config;
+
+   @BeforeMethod
+   public void setUp() throws Exception {
+      config = new AbstractCacheStoreConfig();
+   }
+
+   @AfterMethod
+   public void tearDown() throws CacheLoaderException {
+      config = null;
+   }
+
+   @Test
+   public void testIsPurgeSynchronously() {
+      assert !config.isPurgeSynchronously();
+   }
+
+   @Test
+   public void testSetPurgeSynchronously() {
+      config.setPurgeSynchronously(true);
+      assert config.isPurgeSynchronously();
+   }
+}
\ No newline at end of file

Added: core/branches/flat/src/test/java/org/horizon/loader/AbstractCacheStoreTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/loader/AbstractCacheStoreTest.java	                        (rev 0)
+++ core/branches/flat/src/test/java/org/horizon/loader/AbstractCacheStoreTest.java	2009-03-05 00:22:03 UTC (rev 7852)
@@ -0,0 +1,56 @@
+package org.horizon.loader;
+
+import static org.easymock.classextension.EasyMock.*;
+import org.horizon.util.ReflectionUtil;
+import org.horizon.util.concurrent.WithinThreadExecutor;
+import org.testng.annotations.AfterTest;
+import org.testng.annotations.BeforeTest;
+import org.testng.annotations.Test;
+
+import java.lang.reflect.Method;
+import java.util.concurrent.ExecutorService;
+
+/**
+ * Unit tests that cover {@link  AbstractCacheStoreTest }
+ *
+ * @author Adrian Cole
+ * @version $Id: $
+ * @since 1.0
+ */
+ at Test(groups = "unit", enabled = true, testName = "loader.bdbje.AbstractCacheStoreTest")
+public class AbstractCacheStoreTest {
+   private AbstractCacheStore cs;
+   private AbstractCacheStoreConfig cfg;
+
+   @BeforeTest
+   public void setUp() throws NoSuchMethodException {
+      cs = createMock(AbstractCacheStore.class,new Method[] { AbstractCacheStore.class.getMethod("clear", null) });
+      cfg = new AbstractCacheStoreConfig();
+      cs.init(cfg,null,null);
+   }
+
+   @AfterTest
+   public void tearDown() throws CacheLoaderException {
+      cs.stop();
+      cs = null;
+      cfg = null;
+   }
+
+
+   @Test
+   void testSynchExecutorIsSetWhenCfgPurgeSynchIsTrueOnStart() throws Exception {
+      cfg.setPurgeSynchronously(true);
+      cs.start();
+      ExecutorService service = (ExecutorService) ReflectionUtil.getValue(cs, "purgerService");
+      assert service instanceof WithinThreadExecutor;
+   }
+
+
+   @Test
+   void testASynchExecutorIsDefaultOnStart() throws Exception {
+      cs.start();
+      ExecutorService service = (ExecutorService) ReflectionUtil.getValue(cs, "purgerService");
+      assert !(service instanceof WithinThreadExecutor);
+   }
+
+}