No answer for your question, but you are looking for multicast() and not
for split().
Sent from a mobile device
Am 29.03.2013 15:25 schrieb "dtauzell" <d...@tauzell.org>:
> I have a use case like:
>
> 1. Message comes in
> 2. Send modified version of message to one of many recipients
> 3. Aggregate the responses
>
> I want to have a timeout on the aggregation of responses. If one of the
> recipients takes to long to respond I'll note that in the aggregated
> response and then discard the response when/if it ever comes back. I don't
> need to aggregated responses in any special order.
>
> I thought I could do something like:
>
> split().
> aggregationStrategy(MyAggregationStrategy).
> parallelProcessing().
> streaming().
> timeout(10000).
> to("next route").
> end()
>
> ...
>
> What I would like is that the aggregator gets all the routes that finish in
> the 10 second limit and also to know about the routes that didn't finish.
> It needs to take those into account into the final output.
>
> I created a TimeoutAwareAggregationStrategy but I'm not sure how to use the
> api to do what I want.
>
> Any suggestions?
>
> Thanks,
> Dave
>
>
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Splitter-Aggregation-and-Timeouts-tp5730087.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
