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

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-03-20 08:19:04 -0400 (Thu, 20 Mar 2008)
New Revision: 5455

Removed:
   core/trunk/src/test/java/org/jboss/cache/replicated/ReplicationQueueTest.java
Log:
Repl queue test

Deleted: core/trunk/src/test/java/org/jboss/cache/replicated/ReplicationQueueTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/replicated/ReplicationQueueTest.java	2008-03-20 08:22:10 UTC (rev 5454)
+++ core/trunk/src/test/java/org/jboss/cache/replicated/ReplicationQueueTest.java	2008-03-20 12:19:04 UTC (rev 5455)
@@ -1,50 +0,0 @@
-package org.jboss.cache.replicated;
-
-import org.jboss.cache.Cache;
-import org.jboss.cache.DefaultCacheFactory;
-import org.jboss.cache.config.Configuration;
-import org.jboss.cache.misc.TestingUtil;
-import static org.testng.AssertJUnit.assertNotNull;
-import org.testng.annotations.AfterMethod;
-import org.testng.annotations.BeforeMethod;
-import org.testng.annotations.Test;
-
- at Test(groups = "functional")
-public class ReplicationQueueTest
-{
-   private static final int COUNT = 10;
-   private static final String CONFIG_FILE = "META-INF/pess-repl-async-issue.xml";
-   Cache cache, cache2;
-
-   @BeforeMethod
-   public void setUp() throws CloneNotSupportedException
-   {
-      cache = new DefaultCacheFactory().createCache(false);
-      cache.getConfiguration().setCacheMode(Configuration.CacheMode.REPL_ASYNC);
-      cache.getConfiguration().setUseReplQueue(true);
-      cache.getConfiguration().setReplQueueMaxElements(COUNT);
-      cache.start();
-
-      cache2 = new DefaultCacheFactory().createCache(cache.getConfiguration().clone());
-
-      TestingUtil.blockUntilViewsReceived(60000, cache, cache2);
-   }
-
-   @AfterMethod
-   public void tearDown()
-   {
-      TestingUtil.killCaches(cache, cache2);
-   }
-
-   public void testFailure() throws InterruptedException
-   {
-      for (int i = 0; i < COUNT; i++)
-      {
-         System.out.println("on put i = " + i);
-         cache.put("/a/b/c" + i, "key", "value");
-         assertNotNull(cache.get("/a/b/c" + i, "key"));
-      }
-      Thread.sleep(2000);
-      for (int i = 0; i < COUNT; i++) assertNotNull("on get i = " + i, cache2.get("/a/b/c" + i, "key"));
-   }
-}