svn commit: r734656 - /activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

svn commit: r734656 - /activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java

davsclaus-2
Author: davsclaus
Date: Thu Jan 15 02:18:08 2009
New Revision: 734656

URL: http://svn.apache.org/viewvc?rev=734656&view=rev
Log:
Aligned unit test with camel 2.0 to fix failing in 1.x reported by teamcity

Modified:
    activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java

Modified: activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java?rev=734656&r1=734655&r2=734656&view=diff
==============================================================================
--- activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java (original)
+++ activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java Thu Jan 15 02:18:08 2009
@@ -43,9 +43,11 @@
         executor.execute(new Runnable() {
             public void run() {
                 for (int i = 0; i < 20; i++) {
+                    // when this delay is removed, the seda endpoint has ordering issues
                     try {
                         // do some random sleep to simulate spread in user activity
-                        Thread.sleep(new Random().nextInt(10));
+                        // range is 5-15
+                        Thread.sleep(new Random().nextInt(10) + 5);
                     } catch (InterruptedException e) {
                         // ignore
                     }
@@ -74,7 +76,7 @@
             if (i == 10) {
                 // stop while sending, and then start again to pickup what is left in the queue
                 consumer.stop();
-                Thread.sleep(1000);
+                Thread.sleep(900);
                 consumer.start();
             }
             // use 1000 as timeout otherwise we might get null if the consumer hasn't been started again
@@ -84,5 +86,4 @@
 
         assertMockEndpointsSatisfied();
     }
-
-}
+}
\ No newline at end of file