svn commit: r1056650 - /camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterParallelBigFileTest.java

[da...@apache.org]

Author: davsclaus
Date: Sat Jan  8 07:47:02 2011
New Revision: 1056650

URL: http://svn.apache.org/viewvc?rev=1056650&view=rev
Log:
Fixed compiler issue on JDK 1.5

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

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterParallelBigFileTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterParallelBigFileTest.java?rev=1056650&r1=1056649&r2=1056650&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterParallelBigFileTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterParallelBigFileTest.java Sat Jan  8 07:47:02 2011
@@ -62,12 +62,12 @@ public class SplitterParallelBigFileTest
         StopWatch watch = new StopWatch();
 
         NotifyBuilder builder = new NotifyBuilder(context).whenDone(lines + 1).create();
-        boolean done = builder.matches(5, TimeUnit.MINUTES);
+        boolean done = builder.matches(120, TimeUnit.SECONDS);
 
         log.info("Took " + TimeUtils.printDuration(watch.stop()));
 
         if (!done) {
-            throw new CamelException("Could not split file in 5 minutes");
+            throw new CamelException("Could not split file in 2 minutes");
         }
 
         // need a little sleep for capturing memory profiling
@@ -83,7 +83,7 @@ public class SplitterParallelBigFileTest
                 //context.getExecutorServiceStrategy().getDefaultThreadPoolProfile().setMaxPoolSize(10);
 
                 from("file:target/split")
-                    .split(body().tokenize("\n")).parallelProcessing()
+                    .split(body().tokenize("\n")).streaming().parallelProcessing()
                         .to("log:split?groupSize=1000");
             }
         };