My use case is that I would like to aggregate a batch of messages w/ no correlation strategy before sending it to another channel. Unfortunately, a correlation strategy is required, so I tried the following workaround but it only works for the first batch:
<int:aggregator id = "myAggregator"
input-channel = "inputChannel"
output-channel = "outputChannel"
send-partial-result-on-expiry = "true"
send-timeout = "1000"
correlation-strategy-expression = "1"
release-strategy-expression = "size() gt 20"
Any idea why this only works once?
Thanks in advance,