路由之间的JMS提交 - 我想在Camel中的路由之间提交事务

Posted 2021-04-14

我在camel中使用JMS Transaction

我有两条路线

from("jms:queue:test).process(new Processor(Exchange exchange){
   //place the message to hdfs
   //using hadoop fs api
}).to("direct:ssh")

from("direct:ssh").to(sshCommand)

我想要的是在将消息发送到直接ssh route提交JMS事务之后。不要等待直接ssh路由结果。

目前，仅当我的ssh命令给出结果时才提交Transaction，是否可以在两者之间提交

提前致谢。

答案

我能够进行上述操作，而不是直接使用seda

from("jms:queue:test).process(new Processor(Exchange exchange){
   //place the message to hdfs
   //using hadoop fs api
}).to("seda:ssh")

from("seda:ssh").to(sshCommand)