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);