Aggregator completion timeout

[ljsap1]

I have a requirement where CPI receives data in high volumes, and they need to be collected and sent as bulk messages to the target server. So, the aggregator would have been a good option, however, the messages are flowing all the time, and the aggregator timeout only takes effect when there is a gap between 2 messages - and that would not happen here. It would have been great to have this timeout take effect regardless of the time gap between messages.

There is no indication in the payload as such that identifies a predicate completion neither. The reason to send in bulk is to avoid the target server from getting overloaded, for example, group 1000 messages together and send it as one message rather than 1000 individual messages.

Any ideas what else I could do?

Thank you.

[ljsap1]

Thanks for the reply. I suppose I could also use the datastore and build a custom solution. I was hoping for something more standard but ok.

The messages are already coming from a queue (event mesh) by the way.