跟踪异步服务激活器的进度

Question

我有一个以特定顺序调用某些组件的 spring 集成流程。在最后阶段，通过在 publish-subscribe-channel 上使用 task-executor 并行调用 3 个组件。

<int:publish-subscribe-channel id="pubSubChannel"
    task-executor="executor" />

<int:service-activator id="configure1"
    input-channel="pubSubChannel">
    <bean class="..." />
</int:service-activator>

<int:service-activator id="configure2"
    input-channel="pubSubChannel">
    <bean class="..." />
</int:service-activator>

<int:service-activator id="configure3"
    input-channel="pubSubChannel">
    <bean class="..." />
</int:service-activator>

我想弄清楚所有这些组件何时完成它们的工作，以在正在处理的项目上标记某种成功完成状态。

什么 spring 集成组件或模式可以帮助我实现这一目标？

我想跟踪所有 3 个组件是否已完成且没有错误，并且我想等到所有 3 个组件都完成。

几乎就像这个流程之后的一个通道，它接收所有 3 条消息，并且能够跟踪哪个消息来自哪个激活器/通道，以了解何时收到所有 3 条消息并且工作已经完成。

Answer 1

PublishSubscribeChannel 有applySequence 选项，可以打开true。

PublishSubscribeChannel 使用 SecuneceDetails 标头向每个订阅者发送消息。

<aggregator>（作为默认值）可以查阅这些标头以形成message group，并在所有序列都到达<aggregator> 后准确地产生结果。

您可以在参考手册中找到有关此问题的更多信息。