Spring Integration DSL, опрос из канала сообщений

Question

У меня есть служба, которая отправляет данные в канал сообщений.Мне интересно, как я могу указать поток интеграции для опроса из этого канала сообщений каждые X секунд и чтения всех данных, которые до сих пор не были прочитаны.Я пытаюсь добиться чего-то вроде этого:

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

Answer 1

понял это, я искал это:

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