我有一项将数据发送到消息 channel 的服务。我想知道如何指定集成流每 X 秒从该消息 channel 进行轮询并读取迄今为止尚未读取的所有数据。我正在努力实现这样的目标:
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()
关于java - Spring Integration DSL，从消息 channel 轮询，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/54538005/