Of course, I figure it out 30 minutes after posting. This route works as
desired:
from("stomp:request_queue").
bean(new MyGenerator()).
split(body(), new MyAggregationStrategy()).
parallelProcessing().executorService(Executors.newFixedThreadPool(4)).
bean(new MyRunner()).
end().
recipientList(simple("stomp:${headers[reply-to]}"));
--
View this message in context:
http://camel.465427.n5.nabble.com/Limiting-thread-pool-size-for-parallelProcessing-tp5755185p5755186.html
Sent from the Camel - Users mailing list archive at Nabble.com.
