样本聚合器:
<int:aggregator
input-channel="msgInput"
output-channel="msgOutput"
expire-groups-upon-completion="true"
group-timeout="1000"
expire-groups-upon-timeout="true"
send-partial-result-on-expiry="false"
ref="msgGroup"
/>
序列大小为 2 时,当我手动迭代使用 msgGroup 分组的每条消息的时间戳时,仍有一些(不是全部)消息的差异超过 1000 毫秒。有什么我错过的吗?
请注意,相关 ID 和序列号是根据有效负载以编程方式设置的。因此,某些消息可能具有与序列号相同的相关 ID。