Cron 表达式作为聚合器发布策略

Question

我想在我的链中放置一个 aggregator 来聚合所有传入消息 (String) 并在特定时刻发布聚合消息 (String)，我想使用"cron expression"（就像轮询器中使用的那样）

知道怎么做吗？

谢谢！

Answer 1

由于您只想通过 cron 表达式从聚合器中发布消息，我建议您看一下 MessageGroupStoreReaper，它负责在 forceComplete 上启动操作聚合器。正如您从文档中看到的那样，cron 必须在 <task:scheduled>.

上完成

MessageGroupStoreReaper 的 messageStore 必须是 <aggregator> 中的那个，并且不与其他组件共享。

聚合器配置可能如下所示：

<aggregator message-store="messageStore"
   release-strategy-expression="false"
   expire-groups-upon-completion="true"
   send-partial-result-on-expiry="true"/>

建议在这种情况下实施 ReleaseStrategy，因为只有在新消息到达时才会参考发布策略，因此不可能使用基于时间的发布策略。

Cron 表达式作为聚合器发布策略

Cron expression as an aggregator release strategy

java

spring-integration