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

Minor cleanup

Browse Source
This commit is contained in:
Oleg Zhurakousky
2024-12-22 13:46:20 +01:00
parent 9de725dab0
commit c1cb638591
2 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/util/FunctionWebRequestProcessingHelper.java
View File

@@ -16,6 +16,7 @@
package org.springframework.cloud.function.web.util;
import java.nio.charset.StandardCharsets;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
@@ -233,15 +234,14 @@ public final class FunctionWebRequestProcessingHelper {
else if (result instanceof Mono) {
result = ((Mono) result).map(v -> postProcessResult(v, isMessage));
}
else if (result instanceof Message) {
if (((Message) result).getPayload() instanceof byte[]) {
String str = new String((byte[]) ((Message) result).getPayload());
result = MessageBuilder.withPayload(str).copyHeaders(((Message) result).getHeaders()).build();
else if (result instanceof Message messageResult) {
if (messageResult.getPayload() instanceof byte[]) {
//String str = new String((byte[]) messageResult.getPayload());
result = MessageBuilder.withPayload(messageResult.getPayload()).copyHeaders(((Message) result).getHeaders()).build();
}
}
if (result instanceof byte[]) {
result = new String((byte[]) result);
else if (result instanceof byte[]) {
result = new String((byte[]) result, StandardCharsets.UTF_8);
}
return result;
}