Spring Integration抛ImmediateRequeueAmqpException触发错误日志问题咨询

首先，你通过抛出ImmediateRequeueAmqpException让消息重新入队的处理方式是正确的，这个异常的设计初衷就是告知RabbitMQ将消息立即放回原队列，交由其他消费者实例处理。

至于ConditionalRejectingErrorHandler会记录错误堆栈的原因，核心在于它的默认错误判定策略：默认情况下，该Handler仅会忽略AmqpRejectAndDontRequeueException的日志输出，ImmediateRequeueAmqpException并不在这个默认的“无需日志”异常列表内，因此会触发堆栈日志的记录。

要实现“仅拒绝消息回RabbitMQ，不生成错误日志”的需求，你需要自定义ConditionalRejectingErrorHandler的错误判定逻辑，将ImmediateRequeueAmqpException纳入无需日志的范围，具体实现如下：

自定义错误策略示例 #

@Bean
public ConditionalRejectingErrorHandler errorHandler() {
    return new ConditionalRejectingErrorHandler(new MyErrorStrategy());
}

private static class MyErrorStrategy implements ConditionalRejectingErrorHandler.FatalExceptionStrategy {
    @Override
    public boolean isFatal(Throwable t) {
        // 捕获到ImmediateRequeueAmqpException时，返回false以跳过日志记录
        if (t instanceof ImmediateRequeueAmqpException) {
            return false;
        }
        // 其他异常沿用默认判定逻辑
        return new SimpleFatalExceptionStrategy().isFatal(t);
    }
}

这段代码中，我们自定义了FatalExceptionStrategy：当捕获到ImmediateRequeueAmqpException时返回false，告知ConditionalRejectingErrorHandler该异常无需记录日志；其余异常则继续使用默认的SimpleFatalExceptionStrategy判定逻辑。

修改后，抛出ImmediateRequeueAmqpException时，消息会正常重新入队，同时不会产生错误堆栈日志。

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