2 Replies Latest reply on Sep 13, 2011 7:57 AM by jamie archibald

    splitter + aggregator + thread pool

    jamie archibald Apprentice

      from("direct:input")

      .split(body(), new MyAggregationStrategy())

          .process(...)   // process each object in the array individually

          .end()

      .to("direct:output");

       

       

      I would like to use the above code but rather than processing each message in a single thread I would like it to have each message processed in separate threads.