[hornetq-commits] JBoss hornetq SVN: r9382 - trunk/tests/src/org/hornetq/tests/integration/management.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-07-07 08:50:27 -0400 (Wed, 07 Jul 2010)
New Revision: 9382

Modified:
   trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java
Log:
fix testCreateAndDestroyBridge intermittent failures

Modified: trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java	2010-07-07 08:16:50 UTC (rev 9381)
+++ trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java	2010-07-07 12:50:27 UTC (rev 9382)
@@ -627,6 +627,7 @@
 
       BridgeControl bridgeControl = ManagementControlHelper.createBridgeControl(name, mbeanServer);
       assertEquals(name, bridgeControl.getName());
+      assertTrue(bridgeControl.isStarted());
 
       // check that a message sent to the sourceAddress is put in the tagetQueue
       ClientProducer producer = session.createProducer(sourceAddress);
@@ -635,16 +636,15 @@
       message.putStringProperty("prop", text);
       producer.send(message);
       
-      ClientConsumer sourceConsumer = session.createConsumer(sourceQueue);
-      ClientConsumer targetConsumer = session.createConsumer(targetQueue);
-      
       session.start();
 
+      ClientConsumer targetConsumer = session.createConsumer(targetQueue);
       message = targetConsumer.receive(5000);
       assertNotNull(message);
       assertEquals(text, message.getStringProperty("prop"));
+
+      ClientConsumer sourceConsumer = session.createConsumer(sourceQueue);
       assertNull(sourceConsumer.receiveImmediate());
-
       
       serverControl.destroyBridge(name);