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

Polishing SDK CloudEvent integration

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-03-19 15:52:57 +01:00
parent 675889f549
commit c871e5722a
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/cloudevent/CloudEventsFunctionInvocationHelper.java
View File

@@ -86,15 +86,12 @@ public class CloudEventsFunctionInvocationHelper implements FunctionInvocationHe
@Override @Override
public Message<?> postProcessResult(Object result, Message<?> input) { public Message<?> postProcessResult(Object result, Message<?> input) {
Message<?> convertedResult = null; Object convertedResult = result;
if (this.messageConverter != null && CLOUD_EVENT_CLASS != null && CLOUD_EVENT_CLASS.isAssignableFrom(result.getClass())) { if (this.messageConverter != null && CLOUD_EVENT_CLASS != null && CLOUD_EVENT_CLASS.isAssignableFrom(result.getClass())) {
convertedResult = this.messageConverter.toMessage(result, input.getHeaders()); convertedResult = this.messageConverter.toMessage(result, input.getHeaders());
} }
if (convertedResult == null) { String targetPrefix = CloudEventMessageUtils.determinePrefixToUse(input.getHeaders());
String targetPrefix = CloudEventMessageUtils.determinePrefixToUse(input.getHeaders()); return this.doPostProcessResult(convertedResult, targetPrefix);
convertedResult = this.doPostProcessResult(result, targetPrefix);
}
return convertedResult;
} }
@Override @Override