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

Revert "Polishing previous commit"

Browse Source 
This reverts commit 57b8631e04.
This commit is contained in:
Oleg Zhurakousky
2023-05-24 10:57:23 +02:00
parent 3f8b7f1bbe
commit 53b61e5ebf
1 changed files with 8 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/AWSLambdaUtils.java
View File

@@ -156,7 +156,6 @@ public final class AWSLambdaUtils {
} }
result.add(value); result.add(value);
} }
if (result.size() > 1) { if (result.size() > 1) {
output = result; output = result;
} }
@@ -166,17 +165,15 @@ public final class AWSLambdaUtils {
else { else {
output = null; output = null;
} }
if (output != null && output instanceof Message<?>) { if (output instanceof Message<?> && ((Message<?>) output).getPayload() instanceof byte[]) {
if (output instanceof Message<?>) { responseMessage = (Message<byte[]>) output;
responseMessage = (Message<byte[]>) output; }
} else if (output != null) {
else { if (logger.isDebugEnabled()) {
if (logger.isDebugEnabled()) { logger.debug("OUTPUT: " + output + " - " + output.getClass().getName());
logger.debug("OUTPUT: " + output + " - " + output.getClass().getName());
}
byte[] payload = objectMapper.toJson(output);
responseMessage = MessageBuilder.withPayload(payload).build();
} }
byte[] payload = objectMapper.toJson(output);
responseMessage = MessageBuilder.withPayload(payload).build();
} }
} }
else { else {