svn commit: r766588 - /camel/trunk/camel-core/src/test/java/org/apache/camel/component/timer/TimerRouteTest.java

[davsclaus]

Author: davsclaus
Date: Mon Apr 20 06:23:26 2009
New Revision: 766588

URL: http://svn.apache.org/viewvc?rev=766588&view=rev
Log:
Fixed failing unit test on some slow servers reported by TC.

Modified:
    
camel/trunk/camel-core/src/test/java/org/apache/camel/component/timer/TimerRouteTest.java

Modified: 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/timer/TimerRouteTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/timer/TimerRouteTest.java?rev=766588&r1=766587&r2=766588&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/timer/TimerRouteTest.java
 (original)
+++ 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/timer/TimerRouteTest.java
 Mon Apr 20 06:23:26 2009
@@ -17,11 +17,11 @@
 package org.apache.camel.component.timer;
 
 import java.util.concurrent.atomic.AtomicInteger;
-
 import javax.naming.Context;
 
 import org.apache.camel.ContextTestSupport;
 import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.mock.MockEndpoint;
 import org.apache.camel.util.jndi.JndiContext;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -34,17 +34,19 @@
     private MyBean bean = new MyBean();
 
     public void testTimerInvokesBeanMethod() throws Exception {
-        // now lets wait for the timer to fire a few times.
-        Thread.sleep(1000 * 2);
-        assertTrue("", bean.counter.get() >= 2);
-    }
+        MockEndpoint mock = getMockEndpoint("mock:result");
+        mock.expectedMinimumMessageCount(2);
 
+        assertMockEndpointsSatisfied();
+
+        assertTrue("Should have fired 2 or more times was: " + 
bean.counter.get(), bean.counter.get() >= 2);
+    }
 
     @Override
     protected RouteBuilder createRouteBuilder() throws Exception {
         return new RouteBuilder() {
             public void configure() {
-                
from("timer://foo?fixedRate=true&delay=0&period=500").to("bean:myBean");
+                
from("timer://foo?fixedRate=true&delay=0&period=500").to("bean:myBean", 
"mock:result");
             }
         };
     }