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.
