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