spring - 如何从通用 MessageSource 启动 Spring Integration DSL 轮询器

Question

我们的 Spring Integration DSL 流程之一是一个基于 cron 表达式的简单轮询器。通常，您会配置 PollableChannel 实现(例如 QueueChannel)或使用 InboundAdapter(例如 FTP、HTTPS、S3 等)来处理具有轮询属性的入站消息。

在我们的例子中，我们不会有任何入站消息需要处理。我们只想每晚启动基于 SI DSL 的 IntegrationFlow，最好使用 cron 表达式。有没有什么方法可以让我们使用轮询器启动 SI Flow 或基于 cron 作业“伪造”消息？

Answer 1

IntegrationFlows
        .from(() -> new GenericMessage<>(""),
                e -> e.poller(p -> p.cron("0 0 0 * * ?")))

因为没有像 NullMessage 这样的东西或Message与 null有效负载，我们只是发送一条以空字符串作为有效负载的“假”消息。您可以忽略下游的该消息。

第一个 Lambda 是 MessageSource<T> 的实现正是您提到的 (S)FTP、S3、JDBC 等。

它仍然是相同的入站 channel 适配器，相当于 <int:inbound-channel-adapter ref="">