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

我想在我的链中放置一个聚合器,以聚合所有传入的消息(字符串),并在特定时刻释放聚合的消息(字符串),我想使用“ cron表达式”(如在投票者)

关于如何做到这一点的任何想法？

谢谢！

解决方法:

由于您只想通过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之前执行此操作,因为仅在收到新消息时才咨询发布策略,从而使基于时间的发布策略成为不可能.

标签：java,spring-integration
来源： https://codeday.me/bug/20191120/2040635.html