如何在Camel JMS路由中设置事务

Question

如何在JMS路由中设置事务，以便在发生异常时回滚或不使用消息。下面是我的路线。MQ是ActiveMQ。

from("jms:queue:myQueue")
        .routeId("myRoute")
        .doTry()
            .toF("reactive-streams:myStream")
        .doCatch(Exception.class)
            .process(exchange -> exchange.getFromEndpoint().stop())
        .end();`

Answer 1

只需添加transacted就可以完成此任务！此外，had还启用了连接池和camel-jms-starter (用于默认工厂)。

from("jms:queue:myQueue?transacted=true")
        .routeId("myRoute")
        .doTry()
            .toF("reactive-streams:myStream")
        .doCatch(Exception.class)
            .process(exchange -> exchange.getFromEndpoint().stop())
        .end();