Apache Camel+ActiveMQ Artemis事务问题：exchange.isTransacted()返回false

问题原因 #

你已配置JMS组件的事务参数，但未在路由中显式绑定事务上下文，导致Exchange未关联到事务，因此exchange.isTransacted()返回false。Camel需要通过transacted() DSL将路由节点纳入事务管理，才能让Exchange关联当前事务。

解决方案 #

修改路由类，在消费JMS消息的路由中添加transacted()指定预配置的事务策略：

@Component
public class TransactedJmsRoute extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        from("activeMqTx:foo")
                .transacted("PROPAGATION_REQUIRES_NEW") // 绑定事务策略，开启事务上下文
                .process(new Processor() {
                    @Override
                    public void process(Exchange exchange) throws Exception {
                        String body = exchange.getIn().getBody(String.class);
                        System.out.println("isExchangeTransacted: " + exchange.isTransacted());
                        System.out.println(body);
                        // 可取消注释下方代码测试事务回滚
                        // throw new RuntimeException("Trigger transaction rollback");
                    }
                })
                .to("log:sample");

        from("timer:bar")
                .setBody(constant("Hello from Camel"))
                .to("activeMqTx:foo");
    }
}

额外检查建议 #

• 事务管理器与连接工厂一致性：你的配置已通过@Bean注入保证两者使用同一实例，无需调整。
• 缓存连接工厂优化：可添加缓存参数提升性能，示例如下：

@Bean("cachingConnectionFactory")
public CachingConnectionFactory cachingConnectionFactory() {
    CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory();
    cachingConnectionFactory.setTargetConnectionFactory(activeMqConnectionFactory());
    cachingConnectionFactory.setSessionCacheSize(10); // 设置缓存会话数
    cachingConnectionFactory.setCacheConsumers(true); // 开启消费者缓存
    return cachingConnectionFactory;
}

• 事务有效性验证：在处理器中抛出异常，观察消息是否回滚到队列，确认事务生效。

内容的提问来源于stack exchange，提问作者worldbeater