From ed822167bcebcf09123675ad9f3fabef00beda2f Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Wed, 11 Jan 2012 15:24:12 +0000 Subject: [PATCH] small fix on test --- .../tests/integration/management/QueueControlTest.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java b/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java index 0800d8eb6c1..7214160c3bf 100644 --- 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);