You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/12/16 17:37:33 UTC
svn commit: r891299 -
/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRoutePerformanceCounterTest.java
Author: davsclaus
Date: Wed Dec 16 16:37:32 2009
New Revision: 891299
URL: http://svn.apache.org/viewvc?rev=891299&view=rev
Log:
Fixed unit test on really slow boxes
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRoutePerformanceCounterTest.java
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRoutePerformanceCounterTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRoutePerformanceCounterTest.java?rev=891299&r1=891298&r2=891299&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRoutePerformanceCounterTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRoutePerformanceCounterTest.java Wed Dec 16 16:37:32 2009
@@ -47,9 +47,16 @@
template.asyncSendBody("direct:start", "Hello World");
- Thread.sleep(1500);
-
- Integer inFlight = (Integer) mbeanServer.getAttribute(on, "InflightExchanges");
+ // cater for slow boxes
+ Integer inFlight = null;
+ for (int i = 0; i < 10; i++) {
+ Thread.sleep(500);
+ inFlight = (Integer) mbeanServer.getAttribute(on, "InflightExchanges");
+ if (inFlight.longValue() == 1) {
+ break;
+ }
+ }
+ assertNotNull("too slow server", inFlight);
assertEquals(1, inFlight.longValue());
assertMockEndpointsSatisfied();