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"); } };