svn commit: r921747 - /camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java

[davsclaus]

Author: davsclaus
Date: Thu Mar 11 09:19:08 2010
New Revision: 921747

URL: http://svn.apache.org/viewvc?rev=921747&view=rev
Log:
Fixed test on other boxes

Modified:
    
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java

Modified: 
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java?rev=921747&r1=921746&r2=921747&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java
 (original)
+++ 
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java
 Thu Mar 11 09:19:08 2010
@@ -28,7 +28,7 @@ import org.apache.camel.processor.aggreg
  * @version $Revision$
  */
 public class AggregatorTest extends ContextTestSupport {
-    protected int messageCount = 100;
+    protected int messageCount = 50;
 
     public void testSendingLotsOfMessagesGetAggregatedToTheLatestMessage() 
throws Exception {
         MockEndpoint resultEndpoint = resolveMandatoryEndpoint("mock:result", 
MockEndpoint.class);
@@ -63,7 +63,6 @@ public class AggregatorTest extends Cont
     public void testBatchTimeoutExpiry() throws Exception {
         MockEndpoint resultEndpoint = resolveMandatoryEndpoint("mock:result", 
MockEndpoint.class);
         resultEndpoint.expectedMessageCount(1);
-        resultEndpoint.setSleepForEmptyTest(2 * 
BatchProcessor.DEFAULT_BATCH_TIMEOUT);
         template.sendBodyAndHeader("direct:start", "message:1", "cheese", 123);
         resultEndpoint.assertIsSatisfied();
     }
@@ -73,7 +72,6 @@ public class AggregatorTest extends Cont
         MockEndpoint resultEndpoint = resolveMandatoryEndpoint("mock:result", 
MockEndpoint.class);
         resultEndpoint.expectedMessageCount(1);
         resultEndpoint.message(0).header("visited").isNotNull();
-        resultEndpoint.setSleepForEmptyTest(2 * 
BatchProcessor.DEFAULT_BATCH_TIMEOUT);
         template.sendBodyAndHeader("seda:header", "message:1", "cheese", 123);
         resultEndpoint.assertIsSatisfied();
     }
@@ -111,7 +109,7 @@ public class AggregatorTest extends Cont
             String body = "message:" + i;
             template.sendBodyAndHeader(endpointUri, body, "cheese", 123);
             // need a little sleep when sending large batches
-            Thread.sleep(2);
+            Thread.sleep(3);
         }
 
         resultEndpoint.assertIsSatisfied();