From 643f360a546604d4c9926b30c293f1aaa7030e42 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Thu, 3 Nov 2022 18:08:52 +0100 Subject: [PATCH] Enhance JsonMessage converter to handle byte[] --- .../org/springframework/cloud/function/json/JsonMapper.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/json/JsonMapper.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/json/JsonMapper.java index add2fca9b..88c379f80 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/json/JsonMapper.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/json/JsonMapper.java @@ -77,7 +77,10 @@ public abstract class JsonMapper { logger.debug( "String already represents JSON. Skipping conversion in favor of 'getBytes(StandardCharsets.UTF_8'."); } - result = ((String) value).getBytes(StandardCharsets.UTF_8); + result = value instanceof byte[] ? (byte[]) value : ((String) value).getBytes(StandardCharsets.UTF_8); + } + else if (value instanceof byte[]) { + result = (byte[]) value; } return result; }