Hi All, I implemented my custom aggregation strategy for stateful aggregation. When i tested it, it fails if there is some time latency in sending messages to aggregator, as it timesout.
We tried setting batchTimeout and batchSize with stateful aggregator but it doesn't work as in the default camel implementation, the message counter and the timeout are common to all arriving messages, instead of having separate ones for each aggregate, and so this doesn’t even implement a basic completeness condition. I read camel documentation which says to implement a completeness condition, the camel Aggregator can be extended by writing a custom AggregationCollection, to be used with our custom AggregationStrategy. I request for some urgent help on writing custom AggregationCollection to be used with my Custom AggregationStrategy. best regards, tarandeep [EMAIL PROTECTED] -- View this message in context: http://www.nabble.com/How-to-implement-custom-AggregationCollection-to-implement-completeness-condition-tp17673273s22882p17673273.html Sent from the Camel - Users mailing list archive at Nabble.com.
