java - 如何识别一组消息何时已送达

Question

我有一个 Web 应用程序，允许用户运行大量相同的任务。这些任务由 Spring Integration 中的消息 channel 支持的命令模式执行。

我正在寻找一种方法，将单个批处理中的命令消息逻辑分组在一起，以便设置一个监听器，该监听器能够告知该组中的所有单独消息何时已被处理。

我正在寻找 Spring Integration 中的一种机制来在文档中执行此操作，但我有点不知所措。

Answer 1

参见the aggregator 。您可以指定自定义关联策略来定义组。

默认关联策略使用 correlationId header 。

您需要一个发布策略来确定何时可以发布该组。