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

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2009-01-08 12:05:35 -0500 (Thu, 08 Jan 2009)
New Revision: 7413

Modified:
   core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesWithFailoverTest.java
Log:
enforced cleanup condition

Modified: core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesWithFailoverTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesWithFailoverTest.java	2009-01-08 16:46:33 UTC (rev 7412)
+++ core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesWithFailoverTest.java	2009-01-08 17:05:35 UTC (rev 7413)
@@ -65,10 +65,13 @@
       assertNoLocks(caches);
 
       // gravitate to 2:
-      ReplicationListener replListener1 = ReplicationListener.getReplicationListener(caches.get(0));
+      ReplicationListener replListener0 = ReplicationListener.getReplicationListener(caches.get(0));
+      ReplicationListener replListener1 = ReplicationListener.getReplicationListener(caches.get(1));
+      replListener0.expect(DataGravitationCleanupCommand.class);
       replListener1.expect(DataGravitationCleanupCommand.class);
       caches.get(2).getNode(fqn);  // expectWithTx entire subtree to gravitate.
-      replListener1.waitForReplicationToOccur(); // cleanup commands are async
+      replListener0.waitForReplicationToOccur(); // cleanup commands are async
+      replListener1.waitForReplicationToOccur(); // also wait untill the backup is cleaned
 
       Fqn newBackupFqn = fqnTransformer.getBackupFqn(caches.get(2).getLocalAddress(), fqn);
       Fqn newBackupFqn2 = fqnTransformer.getBackupFqn(caches.get(2).getLocalAddress(), fqn2);