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

GH-856 Fix logic in determining Cloud Event prefix

Browse Source 
Resolves #856
This commit is contained in:
Oleg Zhurakousky
2022-04-26 08:39:26 +02:00
parent 664995d7d1
commit 82e090d163
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -96,7 +96,15 @@ public class CloudEventsFunctionInvocationHelper implements FunctionInvocationHe
if (this.messageConverter != null && CLOUD_EVENT_CLASS != null && CLOUD_EVENT_CLASS.isAssignableFrom(result.getClass())) {
convertedResult = this.messageConverter.toMessage(result, input.getHeaders());
}
String targetPrefix = CloudEventMessageUtils.determinePrefixToUse(input.getHeaders(), true);
String targetPrefix = CloudEventMessageUtils.DEFAULT_ATTR_PREFIX;
if (input != null) {
targetPrefix = CloudEventMessageUtils.determinePrefixToUse(input.getHeaders(), true);
}
else if (result instanceof Message) {
targetPrefix = CloudEventMessageUtils.determinePrefixToUse(((Message<?>) result).getHeaders(), true);
}
Assert.hasText(targetPrefix, "Unable to determine prefix for Cloud Event atttributes, "
+ "which they must have according to protocol specification. Consider adding 'target-protocol' "
+ "header with values of one of the supported protocols - [kafka, amqp, http]");