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

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2009-01-09 03:49:36 -0500 (Fri, 09 Jan 2009)
New Revision: 7420

Modified:
   core/trunk/src/test/java/org/jboss/cache/marshall/AsyncReplTest.java
Log:
default replication timeout

Modified: core/trunk/src/test/java/org/jboss/cache/marshall/AsyncReplTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/marshall/AsyncReplTest.java	2009-01-08 23:52:42 UTC (rev 7419)
+++ core/trunk/src/test/java/org/jboss/cache/marshall/AsyncReplTest.java	2009-01-09 08:49:36 UTC (rev 7420)
@@ -114,11 +114,11 @@
       if (useMarshalledValues) Thread.currentThread().setContextClassLoader(cla);
       replListener2.expect(PutKeyValueCommand.class);
       cache1.put(aop, "person", ben);
-      replListener2.waitForReplicationToOccur(500);
+      replListener2.waitForReplicationToOccur();
 
       replListener2.expect(PutKeyValueCommand.class);
       cache1.put(Fqn.fromString("/alias"), "person", ben);
-      replListener2.waitForReplicationToOccur(500);
+      replListener2.waitForReplicationToOccur();
 
       if (useMarshalledValues) resetContextClassLoader();
 
@@ -143,7 +143,7 @@
       if (useMarshalledValues) Thread.currentThread().setContextClassLoader(clb);
       replListener1.expect(PutKeyValueCommand.class);
       cache2.put(aop, "person", ben2);
-      replListener1.waitForReplicationToOccur(1000);
+      replListener1.waitForReplicationToOccur();
       if (useMarshalledValues) resetContextClassLoader();
       if (useMarshalledValues) Thread.currentThread().setContextClassLoader(cla);
       Object ben3 = cache1.get(aop, "person");
@@ -173,11 +173,11 @@
 
       replListener2.expect(PutKeyValueCommand.class);
       cache1.put(Fqn.fromString("/aop/1"), "person", ben);
-      replListener2.waitForReplicationToOccur(1000);
+      replListener2.waitForReplicationToOccur();
 
       replListener2.expect(PutKeyValueCommand.class);
       cache1.put(Fqn.fromString("/aop/2"), "person", scopedBen1);
-      replListener2.waitForReplicationToOccur(1000);
+      replListener2.waitForReplicationToOccur();
 
       if (useMarshalledValues) resetContextClassLoader();
 
@@ -199,7 +199,7 @@
       beginTransaction();
       cache1.put(aop, "person", ben);
       commit();
-      replListener2.waitForReplicationToOccur(1000);
+      replListener2.waitForReplicationToOccur();
       Person ben2 = (Person) cache2.get(aop, "person");
       assertNotNull("Person from 2nd cache should not be null ", ben2);
       assertEquals(ben.toString(), ben2.toString());
@@ -223,7 +223,7 @@
       beginTransaction();
       cache1.put(aop, "person", ben);
       commit();
-      replListener2.waitForReplicationToOccur(1000);
+      replListener2.waitForReplicationToOccur();
       if (useMarshalledValues) resetContextClassLoader();
 
 
@@ -248,7 +248,7 @@
       replListener1.expect(PutKeyValueCommand.class);
       cache2.put(aop, "person", ben2);
       if (useMarshalledValues) resetContextClassLoader();
-      replListener1.waitForReplicationToOccur(100);
+      replListener1.waitForReplicationToOccur();
       if (useMarshalledValues) Thread.currentThread().setContextClassLoader(cla);
       Object ben3 = cache1.get(aop, "person");
       if (useMarshalledValues) resetContextClassLoader();
@@ -275,7 +275,7 @@
       Fqn fqn = Fqn.fromRelativeElements(base, custom1);
       replListener2.expect(PutKeyValueCommand.class);
       cache1.put(fqn, "key", "value");
-      replListener2.waitForReplicationToOccur(10000);
+      replListener2.waitForReplicationToOccur();
 
       Fqn fqn2 = Fqn.fromRelativeElements(base, custom2);
       Object val = cache2.get(fqn2, "key");