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

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

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

spring-boot java spring spring-integration spring-integration-dsl
person Luka Špoljarić    schedule 05.02.2019    source источник

Ответы (1)


arrow_upward
3
arrow_downward

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

IntegrationFlows.from("inputChannel")
    .handle(myGenericHandlerImpl, e -> e.poller(Pollers.fixedDelay(3, TimeUnit.SECONDS)))
    .get()
person Luka Špoljarić    schedule 05.02.2019