Spring Integration DSL,从消息通道轮询
Posted
技术标签:
【中文标题】Spring Integration DSL,从消息通道轮询【英文标题】:Spring Integration DSL, poll from message channel 【发布时间】:2019-06-29 11:37:13 【问题描述】:我有一个将数据发送到消息通道的服务。我想知道如何指定集成流以每隔 X 秒从该消息通道轮询一次并读取迄今为止尚未读取的所有数据。我正在尝试实现这样的目标:
IntegrationFlows.from("inputChannel")
//.poll(Poller.fixedDelay(3, TimeUnit.SECONDS)))
.handle(myGenericHandlerImpl)
.get()
【问题讨论】:
【参考方案1】:想出了这个 我在找这个:
IntegrationFlows.from("inputChannel")
.handle(myGenericHandlerImpl, e -> e.poller(Pollers.fixedDelay(3, TimeUnit.SECONDS)))
.get()
【讨论】:
以上是关于Spring Integration DSL,从消息通道轮询的主要内容,如果未能解决你的问题,请参考以下文章
Spring Integration DSL:PublishSubscribeChannel 订单
Spring Integration DSL JMS 入站/出站网关