Spring ActiveMQ：如何让jmsTemplate.receive()异常时消息重回队列

你遇到的核心问题是事务回滚未触发消息重回队列，主要原因集中在以下几点：

• 事务管理器与JmsTemplate使用了不同的ConnectionFactory，导致事务无法正确绑定到消息会话
• 自定义异常可能未触发事务回滚（如果是Checked异常）
• CachingConnectionFactory的会话缓存机制干扰了事务回滚后的消息状态

1. 统一ConnectionFactory实例 #

事务管理器必须和JmsTemplate使用同一个ConnectionFactory，否则Spring无法将事务上下文关联到JmsTemplate的消息操作上。修改JmsReceiverConfig中的transactionManager配置：

@Bean
public PlatformTransactionManager transactionManager() {
    JmsTransactionManager transactionManager = new JmsTransactionManager();
    // 改为使用缓存连接工厂，和JmsTemplate保持一致
    transactionManager.setConnectionFactory(cachingConnectionFactory());
    return transactionManager;
}

2. 确保自定义异常触发事务回滚 #

如果FailingMessageProcessingException是Checked异常（未继承RuntimeException），需要在@Transactional注解中显式指定回滚规则：

@Transactional(rollbackFor = FailingMessageProcessingException.class)
public void processingMessage() throws FailingMessageProcessingException {
    // 原有代码不变
}

如果是RuntimeException子类，这一步可跳过，但显式声明更稳妥。

3. 调整CachingConnectionFactory的缓存策略 #

默认CachingConnectionFactory会缓存会话（Session），可能导致事务回滚后，缓存的会话未正确重置消息状态。修改缓存连接工厂的配置，关闭消费者缓存：

@Bean
public CachingConnectionFactory cachingConnectionFactory() {
    ActiveMQConnectionFactory activeMQConnectionFactory = activeMQConnectionFactory();
    CachingConnectionFactory connectionFactory = new CachingConnectionFactory(activeMQConnectionFactory);
    // 关闭消费者缓存，避免会话缓存干扰事务回滚
    connectionFactory.setCacheConsumers(false);
    return connectionFactory;
}

4. 简化JmsTemplate的事务配置 #

由于已经通过Spring的@Transactional管理事务，无需再设置jmsTemplate.setSessionTransacted(true)，避免双重事务管理冲突：

@Bean
public JmsTemplate jmsTemplate() {
    JmsTemplate jmsTemplate = new JmsTemplate(cachingConnectionFactory());
    // 移除setSessionTransacted(true)，由Spring事务管理器统一管理
    return jmsTemplate;
}

5. 配置ActiveMQ消息重发策略（可选） #

为了确保消息回滚后能被重新投递，可在队列上配置重发参数。比如通过Camel创建队列时指定属性：

// 在Camel路由中创建队列时指定重发属性
from("timer:active-mq-timer?period=3000")
        .transform(exchange -> "Message_" + messageNumber.incrementAndGet())
        .to("activemq:entry-queue?jmsMessageType=Text&maxRedeliveries=5&redeliveryDelay=2000");

修改完成后重启应用：

• 抛出FailingMessageProcessingException时，事务会回滚，消息会被放回entry-queue
• 下一次调用jmsTemplate.receive()会重新读取这条失败的消息
• 当重发次数达到最大值后，消息会被转入死信队列dead-letter-queue

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