splitter + aggregator + thread pool

[jamie3_james.archibald]

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.

[davsclaus]

Then enable parallelProcessor on the splitter.

Or configure it to use a specific thread pool (executor service)

See details here also

http://camel.apache.org/splitter.html

http://camel.apache.org/threading-model.html

If you have the Camel in Action book, then the Splitter pattern is covered in chapter 8, and in chapter 10 we also cover parallel processing with EIPs such as the splitter.

[jamie3_james.archibald]

Just found the text in the book that references the splitter+parallel processing.

thanks!