我正在使用 SI-DSL 编写一个 SI 流程,所以让我先说我不知道这个问题是仅与 Si-DSL 相关还是与 SI 和 SI-DSL 相关。
我的用例是这样
的 - 从队列中获取消息 - 将消息保存在数据库表中 - 通过在未来某个时间点选择处于某个特定状态的消息来检索这些消息 - 进一步处理消息......
我的问题是第三步。如果第 3 步是第 1 步,这将很容易,因为我可以只使用 JdbcPollingChannelAdaptera 作为 MessageSource。但是,我找不到在流程中间使用的方法。所以,在 DSL 术语中,我可以做到(其中 dbDataMessageSource 是 JdbcPollingChannelAdapter)
IntegrationFlows
.from(dbDataMessageSource(), p -> p.poller(Pollers.fixedRate(24, TimeUnit.HOURS)))
但我做不到
IntegrationFlows
.from(Jms.messageDrivenChannelAdapter(...))
.handle(new JdbcOutboundGateway(...)
.handle(dbDataMessageSource(), p -> p.poller(Pollers.fixedRate(24, TimeUnit.HOURS)))
我尝试使用网关、网桥、handleWithAdapter 而不是“.handle”,但注意到有效。
有任何想法吗?
干杯。