This is the route I am currently using:
from("jms-cif:queue:" + _notificationQueue).process(processor)
.onException(Exception.class).retryWhile(bean("myRetryBean")).end()
.recipientList(header("recipientListHeader").tokenize(","))
.parallelProcessing()
.timeout(5000)
.executorService(customThreadPoolExecutor)
.streaming()
.aggregationStrategy(new RecipientAggregationStrategy(deliveryEndpoints,
_endpointDeliveredBaseUri))
.to("direct:chunk.completed");
--
View this message in context:
http://camel.465427.n5.nabble.com/camel-2-5-recipientList-aggregationStrategy-timeout-tp2265144p2265279.html
Sent from the Camel - Users mailing list archive at Nabble.com.
