diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/MessageConverterConfigurer.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/MessageConverterConfigurer.java index 6d75bfdaf..6dcc7e0ce 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/MessageConverterConfigurer.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/MessageConverterConfigurer.java @@ -314,8 +314,6 @@ public class MessageConverterConfigurer implements MessageChannelAndSourceConfig boolean propagateOriginalContentType = MessageConverterConfigurer.this.bindingServiceProperties.isPropagateOriginalContentType(); - boolean contentTypeHeaderSet = message.getHeaders().containsKey(MessageHeaders.CONTENT_TYPE); - // ===== 1.3 backward compatibility code part-1 === String ct = null; String oct = null;