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

[davsclaus]

Author: davsclaus
Date: Mon Apr 20 06:22:02 2009
New Revision: 766587

URL: http://svn.apache.org/viewvc?rev=766587&view=rev
Log:
Give slower servers a chance to pass, reported by TC. Notice trunk also uses 10 
as expected message count.

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

Modified: 
camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java
URL: 
http://svn.apache.org/viewvc/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java?rev=766587&r1=766586&r2=766587&view=diff
==============================================================================
--- 
camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java
 (original)
+++ 
camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java
 Mon Apr 20 06:22:02 2009
@@ -44,7 +44,7 @@
         executor.afterPropertiesSet();
         executor.execute(new Runnable() {
             public void run() {
-                for (int i = 0; i < 20; i++) {
+                for (int i = 0; i < 10; i++) {
                     // when this delay is removed, the seda endpoint has 
ordering issues
                     try {
                         // do some random sleep to simulate spread in user 
activity
@@ -66,7 +66,7 @@
 
     public void testStartStopConsumer() throws Exception {
         MockEndpoint mock = getMockEndpoint("mock:result");
-        mock.expectedMessageCount(20);
+        mock.expectedMessageCount(10);
         mock.expectsAscending(body());
 
         initRoute();
@@ -74,7 +74,7 @@
         sendMessagesToQueue();
 
         consumer.start();
-        for (int i = 0; i < 20; i++) {
+        for (int i = 0; i < 10; i++) {
             if (i == 10) {
                 // stop while sending, and then start again to pickup what is 
left in the queue
                 consumer.stop();