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.