svn commit: r933242 - in /camel/trunk/camel-core/src/test/java/org/apache/camel/component/file: FileConcurrentAggregateBatchConsumerTest.java FileConcurrentTest.java

[davsclaus]

Author: davsclaus
Date: Mon Apr 12 14:05:40 2010
New Revision: 933242

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

Modified:
    
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java
    
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.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=933242&r1=933241&r2=933242&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
 Mon Apr 12 14:05:40 2010
@@ -36,7 +36,7 @@ public class FileConcurrentAggregateBatc
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/concurrent")
+                from("file://target/concurrent?sortBy=file:name")
                     .setHeader("id", simple("${file:onlyname.noext}"))
                     .threads(10)
                     .beanRef("business")
@@ -81,7 +81,7 @@ public class FileConcurrentAggregateBatc
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/concurrent")
+                from("file://target/concurrent?sortBy=file:name")
                     .setHeader("id", simple("${file:onlyname.noext}"))
                     .beanRef("business")
                     .aggregate(header("country"), new 
BodyInAggregatingStrategy())

Modified: 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java?rev=933242&r1=933241&r2=933242&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java
 (original)
+++ 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java
 Mon Apr 12 14:05:40 2010
@@ -72,7 +72,7 @@ public class FileConcurrentTest extends 
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/concurrent")
+                from("file://target/concurrent?sortBy=file:name")
                     .setHeader("id", simple("${file:onlyname.noext}"))
                     .threads(10)
                     .beanRef("business")
@@ -118,7 +118,7 @@ public class FileConcurrentTest extends 
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/concurrent")
+                from("file://target/concurrent?sortBy=file:name")
                     .setHeader("id", simple("${file:onlyname.noext}"))
                     .beanRef("business")
                     .aggregate(header("country"), new 
BodyInAggregatingStrategy())