camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Olaf <omgolafg...@gmail.com>
Subject Re: count of processed messages when using aggregation
Date Thu, 14 Nov 2013 14:36:31 GMT
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.

Mime
View raw message