我正在尝试创建一条路由,端点会在传入消息上使用它。目的是将不同数据库和集合中的mongodb写入。
我正在寻找一种简单的方法来从消息标题中获取信息并将其写入到 <to uri=""/>
<route> <from uri="jms:topic:BUS_IN" /> <to uri="mongodb:myDb?database=${header.someValue}&collection=storyTeaser&operation=save" /> </route>
非常感谢
您可以添加第二条路由来设置标头变量:
<route>
<from uri="jms:topic:BUS_IN" />
<camel:setHeader headerName="CamelMongoDbDatabase">
<camel:simple>testmydb</camel:simple>
</camel:setHeader>
<camel:setHeader headerName="CamelMongoDbCollection">
<camel:simple>mycollection</camel:simple>
</camel:setHeader>
<to uri="jms:queue:mongodb.out"/>
</route>
然后在您的第一条路线的uri中添加参数“ dynamicity”:
<route>
<from uri="jms:queue:mongodb.out" />
<to uri="mongodb:myDb?database=new_test&collection=old&dynamicity=true&operation=save"/>
</route>
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句