Skip to content

Commit 3bd3f63

Browse files
committed
GH-1331 Fix header reesolution for cloud events
Resolves #1331
1 parent 43dd7e9 commit 3bd3f63

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

spring-cloud-function-context/src/main/java/org/springframework/cloud/function/cloudevent/CloudEventMessageUtils.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -379,7 +379,12 @@ else if (key.startsWith("amqp")) {
379379
static String determinePrefixToUse(Map<String, Object> messageHeaders, boolean strict) {
380380
String targetProtocol = extractTargetProtocol(messageHeaders);
381381
String prefix = determinePrefixToUse(targetProtocol);
382-
if (StringUtils.hasText(prefix) && (strict || StringUtils.hasText((String) messageHeaders.get(prefix + _SPECVERSION)))) {
382+
Object sv = messageHeaders.get(prefix + _SPECVERSION);
383+
String specVersion = "";
384+
if (sv != null) {
385+
specVersion = sv instanceof String ? (String) sv : new String((byte[]) sv, StandardCharsets.UTF_8);
386+
}
387+
if (StringUtils.hasText(prefix) && (strict || StringUtils.hasText(specVersion))) {
383388
return prefix;
384389
}
385390
else {

0 commit comments

Comments
 (0)