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

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2012-01-11 10:24:12 -0500 (Wed, 11 Jan 2012)
New Revision: 12007

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java
Log:
small fix on test

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java	2012-01-09 11:44:01 UTC (rev 12006)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java	2012-01-11 15:24:12 UTC (rev 12007)
@@ -291,6 +291,12 @@
       ClientMessage message = session.createMessage(false);
       message.putLongProperty(Message.HDR_SCHEDULED_DELIVERY_TIME, System.currentTimeMillis() + delay);
       producer.send(message);
+      
+      long timeout = System.currentTimeMillis() + 5000;
+      while (timeout > System.currentTimeMillis() && queueControl.getScheduledCount() != 1)
+      {
+         Thread.sleep(100);
+      }
 
       Assert.assertEquals(1, queueControl.getScheduledCount());
       ManagementTestBase.consumeMessages(0, session, queue);