1

样本聚合器:

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

4

1 回答 1

0

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

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

于 2015-05-24T14:48:03.303 回答