如何在 Camel JMS Route 中设置事务

【问题标题】：How to setup transaction in Camel JMS Route如何在 Camel JMS Route 中设置事务
【发布时间】：2020-07-05 16:48:23
【问题描述】：

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

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

【问题讨论】：

标签： apache-camel spring-camel camel-jms

【解决方案1】：

只需添加事务就可以了！此外，必须启用连接池和 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();

【讨论】：