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

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-01-30 11:21:16 -0500 (Wed, 30 Jan 2008)
New Revision: 5262

Removed:
   core/trunk/src/test/java/org/jboss/cache/AsyncReplicationQueusFailureTest.java
Log:
JBCACHE-1280 - replication queue messages fail on remote node

Deleted: core/trunk/src/test/java/org/jboss/cache/AsyncReplicationQueusFailureTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/AsyncReplicationQueusFailureTest.java	2008-01-30 15:59:17 UTC (rev 5261)
+++ core/trunk/src/test/java/org/jboss/cache/AsyncReplicationQueusFailureTest.java	2008-01-30 16:21:16 UTC (rev 5262)
@@ -1,38 +0,0 @@
-package org.jboss.cache;
-
-import static org.testng.AssertJUnit.*;
-import org.testng.annotations.Test;
-
-/**
- * Added test to replicate a behavior noticed on certain configs.
- * N.B. This test is not in its final form, it just reproduced the issue and a more appropriate test should
- * replace it after narrowing down the issues. The pess-repl-async-issue.xml config file should be deleted aswell.
- * - guess the issue is caused by using replication q
- */
- at Test(groups = "functional") 
-public class AsyncReplicationQueusFailureTest
-{
-   private static final int COUNT = 10;
-   private static final String CONFIG_FILE = "META-INF/pess-repl-async-issue.xml";
-
-   public void testFailure() throws InterruptedException
-   {
-      Cache cache = DefaultCacheFactory.getInstance().createCache(CONFIG_FILE);
-      Cache cache2 = DefaultCacheFactory.getInstance().createCache(CONFIG_FILE);
-      for (int i = 0; i < COUNT; i++)//if we rise the count to 100k then lots of class cast exception are triggered by JGroups threads
-      {
-         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(10000);
-      for (int i = 0; i < COUNT; i++)
-      {
-         System.out.println("on get i = " + i);
-         assertNotNull(cache2.get("/a/b/c" + i,"key"));         
-      }
-
-      cache.stop();
-      cache2.stop();
-   }
-}