基于Spring-RabbitMQ的Camel消息确认与DLX配置问题

1. 修改RabbitMQ端点配置 #

调整spring-rabbitmq端点参数，关闭自动确认、禁用异常后的自动重入队，并按需配置重试策略：

from("spring-rabbitmq:my-exchange?connectionFactory=#rabbitMQConnectionFactory&queues=my-queue"
        + "&autoAck=false"  // 关闭自动确认，手动控制ACK/NACK
        + "&requeue=false"  // 异常时不重新入队，触发Broker死信逻辑
        + "&retryEnabled=true"
        + "&maxRetryAttempts=3")  // 设置最大重试次数，按需调整
    .onException(Exception.class)
        .log(LoggingLevel.ERROR, "Something went wrong!")
        .markRollbackOnly()  // 标记回滚，触发RabbitMQ发送NACK
        .end()
    .process("myProcessor")
    .ack();  // 处理成功后手动确认消息

2. 异常处理逻辑说明 #

必须在onException中添加markRollbackOnly()，这会告诉Camel的RabbitMQ组件发送NACK且不重新入队的指令给Broker。如果缺少这个配置，Camel会默认将重试耗尽的消息重新入队，无法触发死信机制。

3. 确认Broker端DLX配置（前提） #

确保你的my-queue在RabbitMQ Broker上已正确配置死信参数：

• 队列需设置x-dead-letter-exchange参数，指定死信交换器名称
• 按需设置x-dead-letter-routing-key，匹配死信队列的绑定规则

4. 连接工厂无需额外调整 #

你当前的CachingConnectionFactory配置已满足连接需求，死信转发逻辑由RabbitMQ Broker控制，消费者只需正确发送NACK指令即可触发该流程。

核心逻辑 #

当处理器抛出异常时，markRollbackOnly()触发NACK指令，Broker收到后会按照队列的DLX配置，将消息转发到对应的死信队列。

内容的提问来源于stack exchange，提问作者B. Meert