You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gr...@apache.org on 2010/11/24 11:38:10 UTC
svn commit: r1038548 - in /qpid/branches/0.5.x-dev/qpid/java:
broker/src/test/java/org/apache/qpid/server/stats/
systests/src/main/java/org/apache/qpid/management/jmx/
Author: grkvlt
Date: Wed Nov 24 10:38:09 2010
New Revision: 1038548
URL: http://svn.apache.org/viewvc?rev=1038548&view=rev
Log:
QPID-2932: Fix tests on java persistent profile by adding delays
Modified:
qpid/branches/0.5.x-dev/qpid/java/broker/src/test/java/org/apache/qpid/server/stats/StatisticsCounterTest.java
qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageConnectionStatisticsTest.java
qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java
Modified: qpid/branches/0.5.x-dev/qpid/java/broker/src/test/java/org/apache/qpid/server/stats/StatisticsCounterTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/0.5.x-dev/qpid/java/broker/src/test/java/org/apache/qpid/server/stats/StatisticsCounterTest.java?rev=1038548&r1=1038547&r2=1038548&view=diff
==============================================================================
--- qpid/branches/0.5.x-dev/qpid/java/broker/src/test/java/org/apache/qpid/server/stats/StatisticsCounterTest.java (original)
+++ qpid/branches/0.5.x-dev/qpid/java/broker/src/test/java/org/apache/qpid/server/stats/StatisticsCounterTest.java Wed Nov 24 10:38:09 2010
@@ -81,8 +81,9 @@ public class StatisticsCounterTest exten
StatisticsCounter counter = new StatisticsCounter("test", 1000L);
long start = counter.getStart();
assertEquals(0.0, counter.getPeak());
+ Thread.sleep(500);
counter.registerEvent(1000, start + 500);
- Thread.sleep(1250);
+ Thread.sleep(1000);
assertEquals(1000.0, counter.getPeak());
counter.registerEvent(2000, start + 1500);
Thread.sleep(1000);
@@ -102,10 +103,10 @@ public class StatisticsCounterTest exten
long start = counter.getStart();
assertEquals(0.0, counter.getPeak());
counter.registerEvent(1000, start + 2500);
- Thread.sleep(1250);
+ Thread.sleep(1500);
assertEquals(0.0, counter.getPeak());
counter.registerEvent(2000, start + 1500);
- Thread.sleep(1000);
+ Thread.sleep(1000L);
assertEquals(0.0, counter.getPeak());
counter.registerEvent(1000, start + 500);
Thread.sleep(1500);
@@ -127,9 +128,9 @@ public class StatisticsCounterTest exten
{
StatisticsCounter counter = new StatisticsCounter("test", 1000L);
assertEquals(0.0, counter.getRate());
- Thread.sleep(100);
+ Thread.sleep(500);
counter.registerEvent(1000);
- Thread.sleep(1250);
+ Thread.sleep(1000);
assertEquals(1000.0, counter.getRate());
counter.registerEvent(2000);
Thread.sleep(1000);
Modified: qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageConnectionStatisticsTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageConnectionStatisticsTest.java?rev=1038548&r1=1038547&r2=1038548&view=diff
==============================================================================
--- qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageConnectionStatisticsTest.java (original)
+++ qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageConnectionStatisticsTest.java Wed Nov 24 10:38:09 2010
@@ -76,6 +76,7 @@ public class MessageConnectionStatistics
sendUsing(test, 5, 200);
sendUsing(_test, 5, 200);
+ Thread.sleep(1000);
for (ManagedConnection mc : _jmxUtils.getManagedConnections("test"))
{
Modified: qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java?rev=1038548&r1=1038547&r2=1038548&view=diff
==============================================================================
--- qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java (original)
+++ qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/management/jmx/MessageStatisticsTest.java Wed Nov 24 10:38:09 2010
@@ -48,6 +48,7 @@ public class MessageStatisticsTest exten
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 exten
sendUsing(_test, 10, 100);
sendUsing(temp, 10, 100);
sendUsing(_test, 10, 100);
+ Thread.sleep(2000);
temp.close();
@@ -155,9 +157,9 @@ public class MessageStatisticsTest exten
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 exten
{
sendUsing(_test, 10, 10);
sendUsing(_dev, 10, 10);
+ Thread.sleep(2000);
ManagedBroker test = _jmxUtils.getManagedBroker("test");
ManagedBroker dev = _jmxUtils.getManagedBroker("development");
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org