Spring 集成 DSL，从消息通道轮询
Spring Integration DSL, poll from message 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()
我有一个将数据发送到消息通道的服务。我想知道如何指定集成流以每 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()