From 71ee83ef4b649e673d15139ec726e8237bc60ee8 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Wed, 18 Oct 2023 15:23:32 +0200 Subject: [PATCH] GH-1082 Ensure AWS events are not post-processed Resolves #1082 --- .../cloud/function/adapter/aws/AWSLambdaUtils.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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 30c9bad3f..03fbfa3c0 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 @@ -201,10 +201,7 @@ public final class AWSLambdaUtils { Class outputClass = FunctionTypeUtils.getRawType(functionOutputType); if (outputClass != null) { String outputClassName = outputClass.getName(); - if (outputClassName.equals("com.amazonaws.services.lambda.runtime.events.APIGatewayV2HTTPResponse") || - outputClassName.equals("com.amazonaws.services.lambda.runtime.events.APIGatewayProxyResponseEvent") || - outputClassName.equals("com.amazonaws.services.lambda.runtime.events.ApplicationLoadBalancerResponseEvent") || - outputClassName.equals("com.amazonaws.services.lambda.runtime.events.IamPolicyResponse")) { + if (outputClassName.startsWith("com.amazonaws.services.lambda.runtime.events.")) { return extractPayload((Message) responseMessage, objectMapper); } }