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

Question

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

知道怎么做吗？

谢谢!

Answer 1

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

messageStore对于 MessageGroupStoreReaper一定是来自 <aggregator> 的那个并且不与其他组件共享。

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

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

这比实现 ReleaseStrategy 更推荐在这种情况下，因为只有在新消息到达时才会引用发布策略，因此不可能采用基于时间的发布策略。