spring-integration - 组超时在 Spring Aggregator 中无法按预期工作

Question

样本聚合器：

<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。

Answer 1

我建议您打开调试日志记录并遵循消息流。

我不确定“手动迭代时间戳”是什么意思。组超时与消息时间戳无关；它基于消息到达时间（即最后一次组更新时间）。