File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -919,14 +919,15 @@ private boolean doReceiveAndExecute(BlockingQueueConsumer consumer) throws Excep
919
919
if (this .consumerBatchEnabled ) {
920
920
Collection <MessagePostProcessor > afterReceivePostProcessors = getAfterReceivePostProcessors ();
921
921
if (afterReceivePostProcessors != null ) {
922
+ Message original = message ;
922
923
deliveryTag = message .getMessageProperties ().getDeliveryTag ();
923
924
for (MessagePostProcessor processor : getAfterReceivePostProcessors ()) {
924
925
message = processor .postProcessMessage (message );
925
926
if (message == null ) {
926
927
channel .basicAck (deliveryTag , false );
927
928
if (this .logger .isDebugEnabled ()) {
928
- this .logger
929
- . debug ( "Message Post Processor returned 'null', discarding message " + message );
929
+ this .logger . debug (
930
+ "Message Post Processor returned 'null', discarding message " + original );
930
931
}
931
932
break ;
932
933
}
You can’t perform that action at this time.
0 commit comments