3838public abstract class AbstractMessageHandler extends MessageHandlerSupport
3939 implements MessageHandler , CoreSubscriber <Message <?>> {
4040
41- @ SuppressWarnings ("deprecation" )
41+ @ SuppressWarnings ("deprecation" ) // NOSONAR
4242 public void handleMessage (Message <?> message ) {
43- Assert .notNull (message , "Message must not be null" );
43+ Message <?> messageToUse = message ;
44+ Assert .notNull (messageToUse , "Message must not be null" );
4445 if (isLoggingEnabled () && this .logger .isDebugEnabled ()) {
45- this .logger .debug (this + " received message: " + message );
46+ this .logger .debug (this + " received message: " + messageToUse );
4647 }
4748 org .springframework .integration .support .management .MetricsContext start = null ;
4849 SampleFacade sample = null ;
@@ -52,19 +53,19 @@ public void handleMessage(Message<?> message) {
5253 }
5354 try {
5455 if (shouldTrack ()) {
55- message = MessageHistory .write (message , this , getMessageBuilderFactory ());
56+ messageToUse = MessageHistory .write (messageToUse , this , getMessageBuilderFactory ());
5657 }
5758 AbstractMessageHandlerMetrics handlerMetrics = getHandlerMetrics ();
5859 if (isCountsEnabled ()) {
5960 start = handlerMetrics .beforeHandle ();
60- handleMessageInternal (message );
61+ handleMessageInternal (messageToUse );
6162 if (sample != null ) {
6263 sample .stop (sendTimer ());
6364 }
6465 handlerMetrics .afterHandle (start , true );
6566 }
6667 else {
67- handleMessageInternal (message );
68+ handleMessageInternal (messageToUse );
6869 }
6970 }
7071 catch (Exception e ) {
@@ -74,7 +75,7 @@ public void handleMessage(Message<?> message) {
7475 if (isCountsEnabled ()) {
7576 getHandlerMetrics ().afterHandle (start , false );
7677 }
77- throw IntegrationUtils .wrapInHandlingExceptionIfNecessary (message ,
78+ throw IntegrationUtils .wrapInHandlingExceptionIfNecessary (messageToUse ,
7879 () -> "error occurred in message handler [" + this + "]" , e );
7980 }
8081 }
0 commit comments