java - 如何从 Spring 集成中完成重新排序器中的分组

Question

我使用resequencer以确保消息的正确顺序。当某个具有多个消息的进程结束时，我想再次启动具有相同相关 ID 的相同进程。它不起作用，因为特定相关 ID 的消息组尚未完成，并且对于重新排序器仍然存在，因此没有要释放的消息(所有消息都从头开始重播，因此没有收到序列号大于第一个进程的最后一个消息的消息)。对于 aggregator可以设置expire-groups-upon-completion属性，但resequencer似乎没有这样的功能。是否可以获得所描述的功能？

Answer 1

问题在于，与聚合器不同，从重排序器的角度来看，没有“完成”的概念 - 它无法知道该组是否“完整”。

这就是为什么它不能作为重排序器本身的一个选项。

您可以提供外部 MessageGroupStore bean - 重新排序器默认在内部创建它自己的 SimpleMessageStore，但您可以提供您自己的 bean 的引用。

然后，当您知道该组已“完成”时，您可以使用相关 ID 调用 removeMessageGroup()，这将重置重排序器。