diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/SimpleMessageListenerContainer.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/SimpleMessageListenerContainer.java index 06471602..8f4c293e 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/SimpleMessageListenerContainer.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/SimpleMessageListenerContainer.java @@ -1576,7 +1576,9 @@ public class SimpleMessageListenerContainer extends AbstractMessageListenerConta private void logConsumerException(Throwable t) { if (logger.isDebugEnabled() || !(t instanceof AmqpConnectException || t instanceof ConsumerCancelledException)) { - logger.debug( + // It has to be WARN independently of condition. + // The meaning is: log WARN for all exception when DEBUG enabled, or all others, but mentioned + logger.warn( "Consumer raised exception, processing can restart if the connection factory supports it", t); }