diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java index 9c8acd49..527424c7 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java @@ -1952,7 +1952,7 @@ public class RabbitTemplate extends RabbitAccessor // NOSONAR type line count try { reply = exchangeMessages(exchange, routingKey, message, correlationData, channel, pendingReply, messageTag); - if (this.afterReceivePostProcessors != null) { + if (reply != null && this.afterReceivePostProcessors != null) { for (MessagePostProcessor processor : this.afterReceivePostProcessors) { reply = processor.postProcessMessage(reply); }