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 2010/03/11 17:50:41 UTC
svn commit: r921934 -
/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java
Author: davsclaus
Date: Thu Mar 11 16:50:40 2010
New Revision: 921934
URL: http://svn.apache.org/viewvc?rev=921934&view=rev
Log:
Fixed test on other boxes
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java?rev=921934&r1=921933&r2=921934&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java Thu Mar 11 16:50:40 2010
@@ -40,15 +40,17 @@ public class FileConcurrentAggregateBatc
.threads(20)
.beanRef("business")
.aggregate(header("country"), new MyBusinessTotal())
- .completionTimeout(2000L)
+ .completionTimeout(4000L)
.to("mock:result");
}
});
+ context.start();
long start = System.currentTimeMillis();
MockEndpoint result = getMockEndpoint("mock:result");
result.expectedBodiesReceivedInAnyOrder("2000", "2500");
+ result.setResultWaitTime(20000);
assertMockEndpointsSatisfied();
@@ -64,15 +66,17 @@ public class FileConcurrentAggregateBatc
.setHeader("id", simple("${file:onlyname.noext}"))
.beanRef("business")
.aggregate(header("country"), new MyBusinessTotal())
- .completionTimeout(2000L)
+ .completionTimeout(4000L)
.to("mock:result");
}
});
+ context.start();
long start = System.currentTimeMillis();
MockEndpoint result = getMockEndpoint("mock:result");
result.expectedBodiesReceivedInAnyOrder("2000", "2500");
+ result.setResultWaitTime(20000);
assertMockEndpointsSatisfied();