延迟器持久消息存储弹簧集成

Question

我正在实现一个延迟器，它将定期检查传入的消息，然后将其路由到错误通道。 我知道延迟器会从 MessageStore 中提取消息并在指定的延迟间隔完成后重播。

如果出现MessageStore中有消息而系统宕机的情况怎么办？ volatile MessageStore 中的消息可能丢失？ 我读到可以有一个持久的 MessageStore 绑定到延迟器帮助从此类故障中恢复。 Spring会为你做这件事吗？或者您需要显式配置 JDBCMessageStore。

https://github.com/spring-projects/spring-integration/blob/master/src/reference/asciidoc/delayer.adoc

Answer 1

对目标应用环境没有任何假设，这就是为什么我们默认不提供任何持久性MessageStore。只有一个简单的内存全功能MessageStore。

您只需要选择一个sufficient 实现并注入到您的Delayer bean 定义中。