Require Aggregator Sample code

[mmaligireddy]

Hi All,
I am struggling with crazy aggregator.
Can any one help me on how to configure Aggregator which in connected to Queue channel inorder to group messages based on the time interval.

QueueChannel --> Aggregator --> (grouped messages)

Thanks in Advance,
Mohan Reddy. M

[Mark Fisher]

To control the criteria for grouping, you should consider implementing a CorrelationStrategy and referencing that from the <aggregator>.

Can you describe the use-case a bit more?... how do you determine the time interval and/or how do you determine completeness for any given group?

[mmaligireddy]

Thank you Fisher for your quick reply..
Here I am trying to group all the messages which are coming from QueueChannel within a timeout period. As per the reference manual of SI, Aggregator should group all the messages with default correlationStrategy. I added correlation_id for all the messages which are in QueueChannel and configured aggregator with timeout and sendtimeout attributes. However, Aggregator is not grouping the messages.

If Can you please provide a sample with aggregator which will group the messages in a certain time period.

Thanks
Mohan Reddy.M

[oleg.zhurakousky]

Have you looked at the 'loan-broker' sample which uses an aggregator.
http://blog.springsource.com/2010/09...ation-samples/
You can start from there and use it as a base and then ask a more concrete question related to your use case.