There is also onComplete() but it is triggered right after aggregator
processed last message, not after the route has completed the last message.
Isn't it a bug?
Anyway it wouldn't have the counter in question, I'd only know route has
finished
@Override
public void configure() throws Exception {
from("file:input.csv")
.onCompletion()
.process(new EndProcessor())//
.to("log:sync")
.end()
.unmarshal().csv().split(body()).streaming().parallelProcessing()
.bean("myProcessor", "doWork")
.aggregate(constant("id"), new
Aggregator()).completionSize(100).completionTimeout(1000)
.to("remote")
.log("Sent ${header.RecordsCounter} records to remote");
}
--
View this message in context:
http://camel.465427.n5.nabble.com/count-of-processed-messages-when-using-aggregation-tp5742649p5743292.html
Sent from the Camel - Users mailing list archive at Nabble.com.
