[hornetq-commits] JBoss hornetq SVN: r12007 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/management.
Author: clebert.suconic(a)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);