@@ -113,7 +113,10 @@ public final class AWSLambdaUtils {
|
||||
(((Map<String, Object>) structMessage).containsKey("routeKey") && ((Map) structMessage).containsKey("version")));
|
||||
|
||||
Message<byte[]> requestMessage;
|
||||
MessageBuilder<byte[]> builder = MessageBuilder.withPayload(payload);
|
||||
|
||||
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);
|
||||
if (JsonMapper.isJsonStringRepresentsCollection(((Map) structMessage).get("body"))) {
|
||||
|
||||
Reference in New Issue
Block a user