Spring 集成获取 SQL 流程开始后的数据

Spring Integration Fetch SQL Data after the Flow starts

有一个轮询 JMS 队列的集成流,对于每条消息,使用消息数据中的一个字段需要触发一个 SELECT 查询,然后从中拆分结果以供进一步处理。

如何使用 Java DSL 运行 在流程中间进行 SELECT 查询?尝试使用 JdbcOutboundGateway,它期待 Poller 对象。

谢谢

JdbcOutboundGateway 是解决您的任务的正确方法。它不需要轮询器。这是将要调用此 JdbcOutboundGateway 的端点期望轮询器。只是因为在您的情况下输入通道是 QueueChannel 。不确定为什么在 JMS 队列之后需要一个队列...

Spring集成模型是这样的:

channel -> endpoint (poller) -> message handler (-> channel)

括号 ч 中的任何内容都是可选的,分别取决于通道和消息处理程序的实现。