我尝试使用springboot设置一个简单的骆驼路线。 它从数据库表中读取单个列,并为每一行在 artemis 队列中放置一条消息。
很简单,但我努力从交换主体中获取列值。当我记录结果时,我看到结果集中的每个物体都是
LinkedCaseInsensitiveMap
类型。如果我阅读 camel-sql 文档,这与我所期望的不太一样;对于返回单个列的选择,它应该是列类型(在我的例子中是 int)。
更重要的是,我看不出如何从交换主体中获取单个值并将其转换为另一个主体,然后再将其存储在 artemis 队列中。
我的路线是这样的:
from("direct:test-input")
.log(LoggingLevel.INFO, log,"Received message on test-input")
.to("log:out")
.to("sql: select id from vac_openingen")
.split(body())
// .to("jms:queue:test-messages")
.to("log:out")
每个日志的结果输出是
Exchange[ExchangePattern: InOnly, BodyType: org.springframework.util.LinkedCaseInsensitiveMap, Body: {id=13}]
如何创建一个只有整数值的新交易所?