[hornetq-commits] JBoss hornetq SVN: r10505 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/jms/server/management.
Author: clebert.suconic(a)jboss.com
Date: 2011-04-13 23:30:16 -0400 (Wed, 13 Apr 2011)
New Revision: 10505
Modified:
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControl2Test.java
Log:
Fixing test (adding wait because of async calls) - after JBAPP-6300
Modified:
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControl2Test.java
===================================================================
---
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControl2Test.java 2011-04-13
22:39:12 UTC (rev 10504)
+++
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControl2Test.java 2011-04-14
03:30:16 UTC (rev 10505)
@@ -556,9 +556,23 @@
JMSServerControl2Test.PING_PERIOD);
Connection connection = cf1.createConnection();
- jsonStr = control.listConnectionsAsJSON();
- assertNotNull(jsonStr);
- infos = JMSConnectionInfo.from(jsonStr);
+ long timeout = System.currentTimeMillis() + 5000;
+
+ // Some of the send is asynchronous, so need to wait a few micro seconds
eventually
+ while (System.currentTimeMillis() < timeout)
+ {
+ jsonStr = control.listConnectionsAsJSON();
+ assertNotNull(jsonStr);
+ infos = JMSConnectionInfo.from(jsonStr);
+ if (infos.length == 1)
+ {
+ break;
+ }
+ else
+ {
+ Thread.sleep(500);
+ }
+ }
assertEquals(1, infos.length);
for (JMSConnectionInfo info : infos)
{
@@ -572,9 +586,25 @@
JMSServerControl2Test.PING_PERIOD);
Connection connection2 = cf2.createConnection();
- jsonStr = control.listConnectionsAsJSON();
- assertNotNull(jsonStr);
- infos = JMSConnectionInfo.from(jsonStr);
+ timeout = System.currentTimeMillis() + 5000;
+
+ // Some of the send is asynchronous, so need to wait a few micro seconds
eventually
+ while (System.currentTimeMillis() < timeout)
+ {
+ jsonStr = control.listConnectionsAsJSON();
+ assertNotNull(jsonStr);
+ infos = JMSConnectionInfo.from(jsonStr);
+
+ if (infos.length == 2)
+ {
+ break;
+ }
+ else
+ {
+ Thread.sleep(500);
+ }
+ }
+
assertEquals(2, infos.length);
for (JMSConnectionInfo info : infos)
{