0

我有一个 Spring Integration 路由(通过 DSL 制作),它从特定文件夹轮询文件(如使用 Java DSL 从文件轮询中所示 - 添加 Files.inboundAdapter 时出现编译错误)并发送给 Rabbit。

当我按照上面链接中的说明配置流程时,它已经在配置阶段开始了。但是,我想稍后在运行时启动它,因为我需要先连接到 Rabbit。

如何将 IntegrationFlow 配置为稍后按需启动/停止?

4

1 回答 1

2

添加autoStartup(false).

e -> e.poller(Pollers.fixedDelay(5000))
      .autoStartup(false)

然后flow.start()当你准备好了。

于 2017-06-19T12:29:20.247 回答