small fix on test

hornetq · Jan 11, 2012 · ed82216 · ed82216
1 parent b53faeb
commit ed82216
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java b/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java
@@ -291,6 +291,12 @@ public void testGetScheduledCount() throws Exception
       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);