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

Reply via email to