Scenario:

I split a csv file. A record in this file can consist of several lines. I
therefore use an aggregator to concatenate lines until i have a complete
record and then flush by setting:
exchangeProperty(AGGREGATION_COMPLETE_CURRENT_GROUP, True)
This works fine, but sadly it also causes every subsequent aggregator to
flush if i do not remember to reset the property immediately after the first
aggregator. 

Is there a way to avoid this behavior, or perhaps a better method all
together? 

just to sketch:
from(somefile)
.split(body)
.aggregate() //get records
.process() //doing some processing stuff on individual records
.aggregate // collect some of the records together...except they all get
flushed!
.process() //process these  

thank you in advance





--
View this message in context: 
http://camel.465427.n5.nabble.com/Flush-aggregator-on-tp5793323.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Reply via email to