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

Avoiding classCast exception

Browse Source 
Resolves #991

When messageconverters list has CloudEventMessageConverter before AvroSchemaRegisteryClientMessageConverter,
and message has header contentType = application/*+avro
It results in ClassCastException hence fixing the same.
This commit is contained in:
nagarro-nikhiljagtiani
2023-01-26 01:21:20 +05:30
committed by Oleg Zhurakousky
parent 1a9590f9db
commit 65b17b820c
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

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