[hornetq-commits] JBoss hornetq SVN: r11885 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/spring.

[do-not-reply at jboss.org]

Author: clebert.suconic at 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 at 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();
    }
 }