diff options
Diffstat (limited to 'qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java index 721a464c67..3f9e512631 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java @@ -48,6 +48,7 @@ public class MessageStatisticsTest extends MessageStatisticsTestCase sendUsing(_local, 5, 100); sendUsing(_local, 5, 100); sendUsing(_local, 5, 100); + Thread.sleep(2000); ManagedBroker test = _jmxUtils.getManagedBroker("test"); ManagedBroker dev = _jmxUtils.getManagedBroker("development"); @@ -116,6 +117,7 @@ public class MessageStatisticsTest extends MessageStatisticsTestCase sendUsing(_test, 10, 100); sendUsing(temp, 10, 100); sendUsing(_test, 10, 100); + Thread.sleep(2000); temp.close(); @@ -155,9 +157,9 @@ public class MessageStatisticsTest extends MessageStatisticsTestCase public void testMessagePeakRates() throws Exception { sendUsing(_test, 2, 10); - Thread.sleep(10 * 1000); + Thread.sleep(10000); sendUsing(_dev, 4, 10); - Thread.sleep(10 * 1000); + Thread.sleep(10000); ManagedBroker test = _jmxUtils.getManagedBroker("test"); ManagedBroker dev = _jmxUtils.getManagedBroker("development"); @@ -181,6 +183,7 @@ public class MessageStatisticsTest extends MessageStatisticsTestCase { sendUsing(_test, 10, 10); sendUsing(_dev, 10, 10); + Thread.sleep(2000); ManagedBroker test = _jmxUtils.getManagedBroker("test"); ManagedBroker dev = _jmxUtils.getManagedBroker("development"); |