ActiveMQ Classic重发策略问题：达到最大重发次数后消息未转入目标队列

问题场景 #

配置ActiveMQ Classic重发策略，设置消息最大重发次数为2次，期望达到次数后将消息转入swift_messages_out.DLQ死信队列，但实际消息丢失，未进入目标队列。

代码问题分析 #

1. 死信队列配置方法错误：原代码使用setDestination()指定死信队列，这是错误的——setDestination()是用来定义该重发策略适用的目标队列，而非死信队列。正确的死信队列配置方法是setDeadLetterQueue()。
2. 重发策略目标定义冗余：原代码同时调用了setQueue("swift_messages_out")和setDestination()，两者作用重叠，会导致策略匹配混乱，建议保留其中一种方式明确指定策略适用的队列。

修正后的代码 #

RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
redeliveryPolicy.setInitialRedeliveryDelay(5000);
redeliveryPolicy.setRedeliveryDelay(10000);
redeliveryPolicy.setBackOffMultiplier(2);
redeliveryPolicy.setMaximumRedeliveries(2);
redeliveryPolicy.setUseExponentialBackOff(true);
// 指定该重发策略适用的队列
redeliveryPolicy.setQueue("swift_messages_out");
// 正确配置死信队列
redeliveryPolicy.setDeadLetterQueue(new ActiveMQQueue("swift_messages_out.DLQ"));

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(System.getenv(SwiftWriterProperties.MQ_URI));
connectionFactory.setRedeliveryPolicy(redeliveryPolicy);

JmsTransactionManager transactionManager = new JmsTransactionManager();
transactionManager.setConnectionFactory(connectionFactory);
transactionManager.setRollbackOnCommitFailure(true);
registry.put("jmsTransactionManager", transactionManager);

CamelContext context = new DefaultCamelContext(registry);

ActiveMQComponent activemqComponent;
try {
   String brokerUrl = System.getenv(SwiftWriterProperties.MQ_URI);
   activemqComponent = ActiveMQComponent.activeMQComponent(brokerUrl);
   activemqComponent.setDeliveryPersistent(true);
   activemqComponent.setTransacted(true);
   activemqComponent.setCacheLevelName("CACHE_CONSUMER");
   activemqComponent.setTransactionManager(transactionManager);
   activemqComponent.setConnectionFactory(connectionFactory);
   context.addComponent("jms", activemqComponent);
} catch (Exception e) {
   log.error(e.getLocalizedMessage());
   throw new KantoxException(KantoxExceptionType.FATAL_ERROR, e.getLocalizedMessage());
}

额外注意事项 #

• Broker端全局策略检查：确保ActiveMQ Broker的activemq.xml中没有配置全局死信策略（如deadLetterStrategy）覆盖客户端的重发策略配置。
• 事务回滚触发重发：消费端必须在处理消息失败时回滚事务（比如Camel路由中抛出未捕获的异常），才能触发重发机制，进而在达到最大次数后转入死信队列。
• 持久化消息确认：代码中已设置setDeliveryPersistent(true)，确保消息是持久化的，避免Broker重启时丢失消息。

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