diff --git a/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/AWSLambdaUtils.java b/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/AWSLambdaUtils.java index 6a3d5ad2b..8bba1103a 100644 --- a/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/AWSLambdaUtils.java +++ b/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/AWSLambdaUtils.java @@ -101,21 +101,23 @@ public final class AWSLambdaUtils { } @SuppressWarnings({ "unchecked", "rawtypes" }) - public static Message generateMessage(byte[] payload, Type inputType, boolean isSupplier, JsonMapper jsonMapper, Context context) { + public static Message generateMessage(byte[] payload, Type inputType, boolean isSupplier, + JsonMapper jsonMapper, Context context) { if (logger.isInfoEnabled()) { logger.info("Received: " + new String(payload, StandardCharsets.UTF_8)); } - Object structMessage = jsonMapper.fromJson(payload, Object.class); boolean isApiGateway = structMessage instanceof Map - && (((Map) structMessage).containsKey("httpMethod") || - (((Map) structMessage).containsKey("routeKey") && ((Map) structMessage).containsKey("version"))); + && (((Map) structMessage).containsKey("httpMethod") + || (((Map) structMessage).containsKey("routeKey") + && ((Map) structMessage).containsKey("version"))); Message requestMessage; - - MessageBuilder builder = MessageBuilder.withPayload(structMessage instanceof Map msg && msg.containsKey("payload") - ? ((String) msg.get("payload")).getBytes(StandardCharsets.UTF_8) + + MessageBuilder builder = MessageBuilder + .withPayload(structMessage instanceof Map msg && msg.containsKey("payload") + ? ((String) msg.get("payload")).getBytes(StandardCharsets.UTF_8) : payload); if (isApiGateway) { builder.setHeader(AWSLambdaUtils.AWS_API_GATEWAY, true);