Author: borges Date: 2011-12-02 08:16:40 -0500 (Fri, 02 Dec 2011) New Revision: 11812 Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/util/SameProcessHornetQServer.java Log: Need different instances of the SessionFailureListener, as they end up in a Set of the same SessionFactory. Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/util/SameProcessHornetQServer.java =================================================================== --- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/util/SameProcessHornetQServer.java 2011-12-02 13:16:26 UTC (rev 11811) +++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/util/SameProcessHornetQServer.java 2011-12-02 13:16:40 UTC (rev 11812) @@ -13,6 +13,7 @@ package org.hornetq.tests.integration.cluster.util; +import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import junit.framework.Assert; @@ -84,9 +85,10 @@ public void crash(boolean waitFailure, ClientSession... sessions) throws Exception { - CountDownSessionFailureListener listener = new CountDownSessionFailureListener(sessions.length); + CountDownLatch latch = new CountDownLatch(sessions.length); for (ClientSession session : sessions) { + CountDownSessionFailureListener listener = new CountDownSessionFailureListener(latch); session.addFailureListener(listener); } @@ -99,8 +101,8 @@ if (waitFailure) { // Wait to be informed of failure - boolean ok = listener.getLatch().await(10000, TimeUnit.MILLISECONDS); - Assert.assertTrue("Failed to stop the server! Latch count is " + listener.getLatch().getCount() + " out of " + + boolean ok = latch.await(10000, TimeUnit.MILLISECONDS); + Assert.assertTrue("Failed to stop the server! Latch count is " + latch.getCount() + " out of " + sessions.length, ok); } }