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

SCST-GH-2355 Add support for batch processing of collections with different types

Browse Source 
Specifically KafkaNull. But this commit effectively paves a path for any type
This commit is contained in:
Oleg Zhurakousky
2022-06-08 19:46:35 +02:00
parent a181c50426
commit a14a8d9e9d
1 changed files with 16 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -92,14 +92,16 @@ public class SmartCompositeMessageConverter extends CompositeMessageConverter {
isConverted = true; isConverted = true;
} }
for (Iterator<MessageConverter> iterator = getConverters().iterator(); iterator.hasNext() && !isConverted;) { for (Iterator<MessageConverter> iterator = getConverters().iterator(); iterator.hasNext() && !isConverted;) {
Message<?> m = MessageBuilder.withPayload(item).copyHeaders(message.getHeaders()).build(); // TODO Message creating may be expensive
MessageConverter converter = (MessageConverter) iterator.next(); MessageConverter converter = (MessageConverter) iterator.next();
Object conversionResult = (converter instanceof SmartMessageConverter & genericItemRawType != genericItemType ? if (!converter.getClass().getName().endsWith("ApplicationJsonMessageMarshallingConverter")) { // TODO Stream stuff, needs to be removed
((SmartMessageConverter) converter).fromMessage(m, genericItemRawType, genericItemType) : Message<?> m = MessageBuilder.withPayload(item).copyHeaders(message.getHeaders()).build(); // TODO Message creating may be expensive
converter.fromMessage(m, genericItemRawType)); Object conversionResult = (converter instanceof SmartMessageConverter & genericItemRawType != genericItemType ?
if (conversionResult != null) { ((SmartMessageConverter) converter).fromMessage(m, genericItemRawType, genericItemType) :
resultList.add(conversionResult); converter.fromMessage(m, genericItemRawType));
isConverted = true; if (conversionResult != null) {
resultList.add(conversionResult);
isConverted = true;
}
} }
} }
} }
@@ -107,11 +109,13 @@ public class SmartCompositeMessageConverter extends CompositeMessageConverter {
} }
else { else {
for (MessageConverter converter : getConverters()) { for (MessageConverter converter : getConverters()) {
result = (converter instanceof SmartMessageConverter ? if (!converter.getClass().getName().endsWith("ApplicationJsonMessageMarshallingConverter")) {// TODO Stream stuff, needs to be removed
((SmartMessageConverter) converter).fromMessage(message, targetClass, conversionHint) : result = (converter instanceof SmartMessageConverter ?
converter.fromMessage(message, targetClass)); ((SmartMessageConverter) converter).fromMessage(message, targetClass, conversionHint) :
if (result != null) { converter.fromMessage(message, targetClass));
return result; if (result != null) {
return result;
}
} }
} }
} }