On Thu, Aug 5, 2010 at 12:34 PM, Marco Crivellaro <marco.crivell...@optasports.com> wrote: > > I've noticed you introduced a new timeout for recipientList aggregation, > I can't find a way of adding it to my route: > > from("jms-cif:queue:" + _notificationQueue).process(processor) > > .onException(Exception.class).retryWhile(bean("myRetryBean")).end() > > .recipientList(header("recipientListHeader").tokenize(",")) > .parallelProcessing() > > .executorService(customThreadPoolExecutor) > .streaming() > .aggregationStrategy(new > RecipientAggregationStrategy(deliveryEndpoints, _endpointDeliveredBaseUri)) > .to("direct:chunk.completed"); >
And you are using camel-core-2.5-SNAPSHOT.jar ? See this unit test in camel-core: RecipientListParallelTimeoutTest > regards, > Marco > -- > View this message in context: > http://camel.465427.n5.nabble.com/camel-2-5-recipientList-aggregationStrategy-timeout-tp2265144p2265144.html > Sent from the Camel - Users mailing list archive at Nabble.com. > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus