Spring AMQP：RabbitListenerErrorHandler返回异常消息失败问题

问题原因 #

当你设置returnExceptions = "true"或通过RabbitListenerErrorHandler返回自定义消息时，Spring AMQP需要明确知道回复消息的发送目的地：要么原请求消息携带replyTo属性，要么服务端配置了默认的回复Exchange/队列。如果两者都缺失，就会抛出Cannot determine ReplyTo message property value异常。

解决方案 #

1. 从原始请求消息中获取并复用replyTo属性 #

handleError方法的第一个参数originalMessage是客户端发送的原始请求消息，其中包含客户端指定的replyTo属性。修改ErrorHandler实现，将该属性复制到回复消息中：

@Override
public Object handleError(org.springframework.amqp.core.Message originalMessage, Message<?> failedMessage, ListenerExecutionFailedException e) throws Exception {
    ObjectMapper objectMapper = new ObjectMapper();
    byte[] responseBody = objectMapper.writeValueAsString(myCustomData).getBytes();

    // 复制原始消息的属性，包含replyTo
    MessageProperties replyProperties = new MessageProperties();
    replyProperties.copyProperties(originalMessage.getMessageProperties());

    // 构建并返回回复消息
    return MessageBuilder.withBody(responseBody)
            .andProperties(replyProperties)
            .build();
}

2. 配置默认回复目的地（如果原消息无replyTo） #

如果客户端发送请求时未指定replyTo，可以在服务端的RabbitListener容器工厂中配置默认回复队列/Exchange，确保异常消息有发送目标：

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    // 设置默认回复队列
    factory.setDefaultReplyTo("default_reply_queue");
    // 若需通过Exchange转发，可配置以下两项
    // factory.setDefaultReplyToExchange("default_reply_exchange");
    // factory.setDefaultReplyToRoutingKey("default_reply_routing_key");
    return factory;
}

3. 关键注意事项 #

• 必须从原始请求消息（handleError的第一个参数）中获取replyTo，而非失败消息的属性，因为原始消息才是客户端发送的请求载体。
• 如果仅需返回默认异常信息，使用returnExceptions = "true"即可，无需自定义ErrorHandler，但同样需要确保replyTo存在或配置了默认回复目的地。

内容的提问来源于stack exchange，提问作者İlkay Gunel