This problem can be solved by a stream resequencer. (http://camel.apache.org/resequencer.html - stream resequencing) It will reorder the exchanges after being processed and send them to the aggregator. You have to reorder them so that the exchange with the split complete is always the last one, and this way you can remove the timeout on the aggregator and add a predicate: completionPredicate(header("CamelSplitComplete").isEqualTo(true))
-- View this message in context: http://camel.465427.n5.nabble.com/count-of-processed-messages-when-using-aggregation-tp5742649p5743210.html Sent from the Camel - Users mailing list archive at Nabble.com.
