You can use batchTimeout to control when the aggregator will finish.
Alternatively a completionPredicate can accomplish the same thing. Bear
in mind that they are mutually exclusive.
contactreji wrote:
Hey guys
My downstream system doesn't take more than 1000 records in one go. I am
using aggregator to create batch composed from 1000 exchanges.
Now if my upstream system sends 8020 messages, the aggregator collects 8
batches of 1000 each. And the last 20 remains in the aggregator
waiting for
rest 980 more to come before its forwarded.
Now is there a way that we can instruct camel to release this remaining 20
as well after waiting for a certain period of time?
Reji
-----
Reji Mathews
Sr. Developer - Middleware Integration / SOA ( Open Source - Apache
Camel& Jboss Fuse ESB | Mule ESB )
LinkedIn - http://in.linkedin.com/pub/reji-mathews/31/9a2/40a
Twitter - reji_mathews
--
View this message in context:
http://camel.465427.n5.nabble.com/Controlling-Bucket-size-for-camel-aggregator-tp5781015.html
Sent from the Camel - Users mailing list archive at Nabble.com.
