java - Spring Integration DSL，从消息 channel 轮询

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

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

最佳答案

想通了这个
我一直在寻找这个：

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