From f669d65f4ebdb4e2740a8add649ea85c361bc4bf Mon Sep 17 00:00:00 2001 From: Prajesh Ravindran Date: Thu, 5 Nov 2020 09:23:41 -0800 Subject: [PATCH 1/3] Add ActiveMQ event --- .../lambda/runtime/events/ActiveMQEvent.java | 65 +++++++++++++++++++ 1 file changed, 65 insertions(+) create mode 100644 aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java new file mode 100644 index 00000000..68581f8c --- /dev/null +++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java @@ -0,0 +1,65 @@ +/* + * Copyright 2015-2020 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with + * the License. A copy of the License is located at + * + * http://aws.amazon.com/apache2.0 + * + * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR + * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions + * and limitations under the License. + */ +package com.amazonaws.services.lambda.runtime.events; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import java.util.List; + +@Data +@NoArgsConstructor +@AllArgsConstructor +@Builder(setterPrefix = "with") +public class ActiveMQEvent { + private String eventSource; + private String eventSourceArn; + private List messages; + + /** + * Represents an Active MQ event sent to Lambda. + */ + @Data + @NoArgsConstructor + @AllArgsConstructor + @EqualsAndHashCode + @Builder(setterPrefix = "with") + public static class ActiveMQMessage { + private String messageID; + private String messageType; + private long timestamp; + private int deliveryMode; + private String correlationID; + private String replyTo; + private Destination destination; + private boolean redelivered; + private String type; + private long expiration; + private int priority; + /** Message data sent to Active MQ broker encooded in Base 64 **/ + private String data; + private long brokerInTime; + private long brokerOutTime; + } + + @Data + @NoArgsConstructor + @AllArgsConstructor + @Builder(setterPrefix = "with") + public static class Destination { + /** Queue Name **/ + private String physicalName; + } +} From 21d521b33bda73aee65fac8bf116d0ff7be26354 Mon Sep 17 00:00:00 2001 From: Prajesh Ravindran Date: Thu, 5 Nov 2020 20:20:14 -0800 Subject: [PATCH 2/3] Add link to Amazon MQ as event source --- .../services/lambda/runtime/events/ActiveMQEvent.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java index 68581f8c..227bbc5e 100644 --- a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java +++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java @@ -23,14 +23,15 @@ @NoArgsConstructor @AllArgsConstructor @Builder(setterPrefix = "with") +/** +* Represents an Active MQ event sent to Lambda +* Onboarding Amazon MQ as event source to Lambda +*/ public class ActiveMQEvent { private String eventSource; private String eventSourceArn; private List messages; - /** - * Represents an Active MQ event sent to Lambda. - */ @Data @NoArgsConstructor @AllArgsConstructor From 97e36cd931fb2e7ab3a8780c59f65f1d0a31435d Mon Sep 17 00:00:00 2001 From: Carl Zogheib <11421173+carlzogh@users.noreply.github.com> Date: Fri, 6 Nov 2020 09:04:35 +0000 Subject: [PATCH 3/3] Update ActiveMQEvent.java --- .../services/lambda/runtime/events/ActiveMQEvent.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java index 227bbc5e..46791980 100644 --- a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java +++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/ActiveMQEvent.java @@ -19,14 +19,14 @@ import lombok.NoArgsConstructor; import java.util.List; -@Data -@NoArgsConstructor -@AllArgsConstructor -@Builder(setterPrefix = "with") /** * Represents an Active MQ event sent to Lambda * Onboarding Amazon MQ as event source to Lambda */ +@Data +@NoArgsConstructor +@AllArgsConstructor +@Builder(setterPrefix = "with") public class ActiveMQEvent { private String eventSource; private String eventSourceArn; @@ -35,7 +35,6 @@ public class ActiveMQEvent { @Data @NoArgsConstructor @AllArgsConstructor - @EqualsAndHashCode @Builder(setterPrefix = "with") public static class ActiveMQMessage { private String messageID;