您如何确保 Spring Integration poller 在服务重新启动时正常工作并执行错过的计划?
How do you make sure that Spring Integration poller works and executes missed schedules when a service is restarted?
IntegrationFlows
.from(() -> new GenericMessage<>(""),
e -> e.poller(p -> p.cron("0 0/5 * 1/1 * *")))
在上述集成流程的情况下,存在将空消息推送到特定队列的 cron 计划。如果计划真的很长(假设每 2 周一次),并且在应该执行计划的时间,服务将重新启动或关闭。我们如何确保它在服务备份后立即执行? Spring 集成是否默认执行此操作? (我在文档中找不到任何内容)
框架中没有内置任何内容来处理由于应用程序未在预期执行时 运行 而错过的执行。
对于如此大的执行延迟,最好使用外部调度程序(anacron 等)。
IntegrationFlows
.from(() -> new GenericMessage<>(""),
e -> e.poller(p -> p.cron("0 0/5 * 1/1 * *")))
在上述集成流程的情况下,存在将空消息推送到特定队列的 cron 计划。如果计划真的很长(假设每 2 周一次),并且在应该执行计划的时间,服务将重新启动或关闭。我们如何确保它在服务备份后立即执行? Spring 集成是否默认执行此操作? (我在文档中找不到任何内容)
框架中没有内置任何内容来处理由于应用程序未在预期执行时 运行 而错过的执行。
对于如此大的执行延迟,最好使用外部调度程序(anacron 等)。