svn commit: r769056 - /camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java

[da...@apache.org]

Author: davsclaus
Date: Mon Apr 27 16:44:06 2009
New Revision: 769056

URL: http://svn.apache.org/viewvc?rev=769056&view=rev
Log:
Tried to fix unit test that fails occational on Apache hudson server.

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

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java?rev=769056&r1=769055&r2=769056&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java Mon Apr 27 16:44:06 2009
@@ -105,9 +105,7 @@
         assertMockEndpointsSatisfied();
 
         List<Exchange> list = resultEndpoint.getReceivedExchanges();
-
         Set<Integer> numbersFound = new TreeSet<Integer>();
-
         final String[] names = {"James", "Guillaume", "Hiram", "Rob"};
 
         for (int i = 0; i < 4; i++) {
@@ -180,7 +178,6 @@
             //this header cannot be set when streaming is used
             assertNull(exchange.getIn().getHeader(Exchange.SPLIT_SIZE));
         }
-
     }
     
     public void testSplitterWithException() throws Exception {
@@ -209,14 +206,19 @@
         return new RouteBuilder() {
             public void configure() {
                 errorHandler(deadLetterChannel("mock:failed").maximumRedeliveries(0));
+
                 from("direct:seqential").split(body().tokenize(","), new UseLatestAggregationStrategy()).to("mock:result");
+
                 from("direct:parallel").split(body().tokenize(","), new MyAggregationStrategy()).parallelProcessing(true).to("mock:result");
+
                 from("direct:streaming").split(body().tokenize(",")).streaming().to("mock:result");
+
                 from("direct:parallel-streaming").split(body().tokenize(","), new MyAggregationStrategy()).parallelProcessing().streaming().to("mock:result");
+
                 from("direct:exception")
                     .split(body().tokenize(","))
                     .aggregationStrategy(new MyAggregationStrategy())
-                    .parallelProcessing(true).streaming()
+                    .parallelProcessing(true)
                     .process(new Processor() {
                         public void process(Exchange exchange) throws Exception {
                             String string = exchange.getIn().getBody(String.class);