SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

polishing

Browse Source
This commit is contained in:
Oleg Zhurakousky
2018-12-13 16:54:39 +01:00
parent f080ca6cb0
commit d81cb16dfb
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/MessageConverterConfigurer.java
View File

@@ -352,12 +352,10 @@ public class MessageConverterConfigurer implements MessageChannelAndSourceConfig
}
}
else {
if (!contentTypeHeaderSet) {
@SuppressWarnings("unchecked")
Map<String, Object> headersMap = (Map<String, Object>) ReflectionUtils.getField(MessageConverterConfigurer.this.headersField,
outboundMessage.getHeaders());
headersMap.remove(MessageHeaders.CONTENT_TYPE);
}
@SuppressWarnings("unchecked")
Map<String, Object> headersMap = (Map<String, Object>) ReflectionUtils.getField(MessageConverterConfigurer.this.headersField,
outboundMessage.getHeaders());
headersMap.remove(MessageHeaders.CONTENT_TYPE);
}
// ===== END 1.3 backward compatibility code part-2 ===
return outboundMessage;