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

GH-739 Add DEBUG log statement for when type conversion fails

Browse Source 
Resolves #739
This commit is contained in:
Oleg Zhurakousky
2022-05-04 14:59:38 +02:00
parent 63ad1dead6
commit 080be7f40c
2 changed files with 173 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -19,6 +19,9 @@ package org.springframework.cloud.function.context.config;
import java.util.Collection;
import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.lang.Nullable;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;
@@ -37,6 +40,8 @@ import org.springframework.util.StringUtils;
*/
public class SmartCompositeMessageConverter extends CompositeMessageConverter {
private Log logger = LogFactory.getLog(this.getClass());
public SmartCompositeMessageConverter(Collection<MessageConverter> converters) {
super(converters);
}
@@ -48,9 +53,16 @@ public class SmartCompositeMessageConverter extends CompositeMessageConverter {
if (!(message.getPayload() instanceof byte[]) && targetClass.isInstance(message.getPayload()) && !(message.getPayload() instanceof Collection<?>)) {
return message.getPayload();
}
Object result = converter.fromMessage(message, targetClass);
if (result != null) {
return result;
try {
Object result = converter.fromMessage(message, targetClass);
if (result != null) {
return result;
}
}
catch (Exception e) {
if (logger.isDebugEnabled()) {
logger.debug("Failure during type conversion by " + converter + ". Will try the next converter.", e);
}
}
}
return null;