Author: mircea.markus Date: 2009-01-20 10:28:09 -0500 (Tue, 20 Jan 2009) New Revision: 7533 Modified: core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesNoPoolWithDataGravitationTest.java core/trunk/src/test/java/org/jboss/cache/buddyreplication/BuddyReplicationTestsBase.java Log: more strict replication controll Modified: core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesNoPoolWithDataGravitationTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesNoPoolWithDataGravitationTest.java 2009-01-20 15:27:34 UTC (rev 7532) +++ core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesNoPoolWithDataGravitationTest.java 2009-01-20 15:28:09 UTC (rev 7533) @@ -458,12 +458,12 @@ assertEquals("value", caches.get(0).get("/2", "key")); caches.get(0).stop(); - caches = createCaches(3, false, true); - replicationListener0 = ReplicationListener.getReplicationListener(caches.get(0)); - replicationListener1 = ReplicationListener.getReplicationListener(caches.get(1)); - replicationListener2 = ReplicationListener.getReplicationListener(caches.get(2)); - - waitForSingleBuddy(caches); + //uncoment this if you want to run this test more than once +// caches = createCaches(3, false, true); +// replicationListener0 = ReplicationListener.getReplicationListener(caches.get(0)); +// replicationListener1 = ReplicationListener.getReplicationListener(caches.get(1)); +// replicationListener2 = ReplicationListener.getReplicationListener(caches.get(2)); +// waitForSingleBuddy(caches); } } Modified: core/trunk/src/test/java/org/jboss/cache/buddyreplication/BuddyReplicationTestsBase.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/buddyreplication/BuddyReplicationTestsBase.java 2009-01-20 15:27:34 UTC (rev 7532) +++ core/trunk/src/test/java/org/jboss/cache/buddyreplication/BuddyReplicationTestsBase.java 2009-01-20 15:28:09 UTC (rev 7533) @@ -101,7 +101,7 @@ } else { - c.removeNode(Fqn.ROOT); + if (c.getComponentRegistry().getState().allowInvocations()) c.removeNode(Fqn.ROOT); } } }