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) {