Author: clebert.suconic(a)jboss.com Date: 2011-12-08 15:35:26 -0500 (Thu, 08 Dec 2011) New Revision: 11885 Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/spring/ExampleListener.java Log: fixing test Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/spring/ExampleListener.java =================================================================== --- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/spring/ExampleListener.java 2011-12-08 20:24:48 UTC (rev 11884) +++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/spring/ExampleListener.java 2011-12-08 20:35:26 UTC (rev 11885) @@ -5,6 +5,8 @@ import javax.jms.MessageListener; import javax.jms.TextMessage; +import org.hornetq.utils.ReusableLatch; + /** * @author <a href="mailto:bill@burkecentral.com">Bill Burke</a> * @version $Revision: 1 $ @@ -12,6 +14,8 @@ public class ExampleListener implements MessageListener { public static String lastMessage = null; + + public static ReusableLatch latch = new ReusableLatch(); public void onMessage(Message message) { @@ -24,5 +28,6 @@ throw new RuntimeException(e); } System.out.println("MESSAGE RECEIVED: " + lastMessage); + latch.countDown(); } }