Spring Integration DSL，从消息通道轮询答案

【问题标题】：Spring Integration DSL, poll from message channelSpring Integration DSL，从消息通道轮询
【发布时间】：2019-06-29 11:37:13
【问题描述】：

我有一个将数据发送到消息通道的服务。我想知道如何指定集成流以每隔 X 秒从该消息通道轮询一次并读取迄今为止尚未读取的所有数据。我正在尝试实现这样的目标：

IntegrationFlows.from("inputChannel")
    //.poll(Poller.fixedDelay(3, TimeUnit.SECONDS)))
    .handle(myGenericHandlerImpl)
    .get()

【问题讨论】：

【解决方案1】：

想出了这个我在找这个：

IntegrationFlows.from("inputChannel")
    .handle(myGenericHandlerImpl, e -> e.poller(Pollers.fixedDelay(3, TimeUnit.SECONDS)))
    .get()

【讨论】：