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)
括号 ч 中的任何内容都是可选的,分别取决于通道和消息处理程序的实现。
有一个轮询 JMS 队列的集成流,对于每条消息,使用消息数据中的一个字段需要触发一个 SELECT 查询,然后从中拆分结果以供进一步处理。
如何使用 Java DSL 运行 在流程中间进行 SELECT 查询?尝试使用 JdbcOutboundGateway
,它期待 Poller
对象。
谢谢
JdbcOutboundGateway
是解决您的任务的正确方法。它不需要轮询器。这是将要调用此 JdbcOutboundGateway
的端点期望轮询器。只是因为在您的情况下输入通道是 QueueChannel
。不确定为什么在 JMS 队列之后需要一个队列...
Spring集成模型是这样的:
channel -> endpoint (poller) -> message handler (-> channel)
括号 ч 中的任何内容都是可选的,分别取决于通道和消息处理程序的实现。