[hornetq-commits] JBoss hornetq SVN: r11884 - 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:24:48 -0500 (Thu, 08 Dec 2011)
New Revision: 11884

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/spring/SpringIntegrationTest.java
Log:
fixing test

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/spring/SpringIntegrationTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/spring/SpringIntegrationTest.java	2011-12-08 18:22:55 UTC (rev 11883)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/spring/SpringIntegrationTest.java	2011-12-08 20:24:48 UTC (rev 11884)
@@ -1,5 +1,7 @@
 package org.hornetq.tests.integration.spring;
 
+import java.util.concurrent.TimeUnit;
+
 import junit.framework.Assert;
 
 import org.hornetq.core.logging.Logger;
@@ -34,9 +36,12 @@
       {
          MessageSender sender = (MessageSender)context.getBean("MessageSender");
          System.out.println("Sending message...");
+         ExampleListener.latch.countUp();
          sender.send("Hello world");
-         Thread.sleep(100);
+         ExampleListener.latch.await(10, TimeUnit.SECONDS);
+         Thread.sleep(500);
          Assert.assertEquals(ExampleListener.lastMessage, "Hello world");
+         System.out.println("done!");
          ((HornetQConnectionFactory)sender.getConnectionFactory()).close();
       }
       finally