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

GH-773 Fix wild card type matching in SmartCompositeMessageConverter

Browse Source 
Resolves #773
This commit is contained in:
Oleg Zhurakousky
2021-11-29 17:10:49 +01:00
parent a5ed2e8fb6
commit dc34f3eb6b
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/SmartCompositeMessageConverter.java
View File

@@ -74,18 +74,21 @@ public class SmartCompositeMessageConverter extends CompositeMessageConverter {
if (headers.get(MessageHeaders.CONTENT_TYPE) == null) { if (headers.get(MessageHeaders.CONTENT_TYPE) == null) {
return null; return null;
} }
Object value = headers.get(MessageHeaders.CONTENT_TYPE).toString(); Object value = headers.get(MessageHeaders.CONTENT_TYPE).toString();
String[] contentTypes = StringUtils.delimitedListToStringArray((String) value, ","); String[] contentTypes = StringUtils.delimitedListToStringArray((String) value, ",");
for (String contentType : contentTypes) { for (String contentType : contentTypes) {
if (!MimeType.valueOf(contentType).isConcrete()) { if (!MimeType.valueOf(contentType).isConcrete()) {
List<MimeType> supportedMimeTypes = ((AbstractMessageConverter) converter).getSupportedMimeTypes(); List<MimeType> supportedMimeTypes = ((AbstractMessageConverter) converter).getSupportedMimeTypes();
for (MimeType supportedMimeType : supportedMimeTypes) { for (MimeType supportedMimeType : supportedMimeTypes) {
MessageHeaderAccessor h = new MessageHeaderAccessor(); if (supportedMimeType.isCompatibleWith(MimeType.valueOf(contentType))) {
h.copyHeaders(headers); MessageHeaderAccessor h = new MessageHeaderAccessor();
h.setHeader(MessageHeaders.CONTENT_TYPE, supportedMimeType); h.copyHeaders(headers);
Message<?> result = converter.toMessage(payload, h.getMessageHeaders()); h.setHeader(MessageHeaders.CONTENT_TYPE, supportedMimeType);
if (result != null) { Message<?> result = converter.toMessage(payload, h.getMessageHeaders());
return result; if (result != null) {
return result;
}
} }
} }
} }