Add SQS to the list of java-events examples.

- The blank-java example is just a Lambda function that handles SQSEvent objects.
- Moved this example to inside the java-events folder.
- Tested this change using the sqs path, as well as ensured current examples still work.

Author: yualexan

sample-apps/.gitignore

@@ -11,8 +11,8 @@ build
 *.zip
 bin
 obj
-main
 Gemfile.lock
 lib
 __pycache__
 *.pyc
+.DS_Store

sample-apps/java-events/3-invoke.sh

@@ -40,6 +40,9 @@ then
     s3)
       PAYLOAD='file://events/s3-notification.json'
       ;;
+    sqs)
+      PAYLOAD='file://events/sqs-record.json'
+      ;;
     *)
       echo -n "Unknown event type"
       ;;

sample-apps/java-events/README.md

@@ -98,6 +98,7 @@ By default, the function uses a handler class named `Handler` that takes an API
 - `HandlerLex.java` - Takes `LexEvent` as input.
 - `HandlerS3.java` - Takes `S3Event` as input.
 - `HandlerSNS.java` - Takes `SNSEvent` as input.
+- `HandlerSQS.java` - Takes `SQSEvent` as input.
 
 To use a different handler, change the value of the Handler setting in the application template (`template.yml` or `template-mvn.yaml`). For example, to use the Amazon Lex handler:
 
@@ -128,6 +129,7 @@ The following event type keys are supported:
 - `lex` - Lex dialog (`events/lex-flowers.json`)
 - `ddb` - DynamoDB record (`events/dynamodb-record.json`)
 - `s3` - S3Event record (`events/s3-notification.json`)
+- `sqs` - SQSEvent record (`events/sqs-record.json`)
 
 # Cleanup
 To delete the application, run `4-cleanup.sh`.

sample-apps/java-events/build.gradle

@@ -8,7 +8,7 @@ repositories {
 
 dependencies {
     implementation 'com.amazonaws:aws-lambda-java-core:1.2.1'
-    implementation 'com.amazonaws:aws-lambda-java-events:3.9.0'
+    implementation 'com.amazonaws:aws-lambda-java-events:3.11.0'
     implementation 'com.google.code.gson:gson:2.8.6'
     implementation 'org.apache.logging.log4j:log4j-api:[2.17.1,)'
     implementation 'org.apache.logging.log4j:log4j-core:[2.17.1,)'

sample-apps/java-events/events/sqs-record.json

@@ -0,0 +1,20 @@
+{
+    "Records": [
+        {
+            "messageId": "19dd0b57-b21e-4ac1-bd88-01bbb068cb78",
+            "receiptHandle": "MessageReceiptHandle",
+            "body": "Hello from SQS!",
+            "attributes": {
+                "ApproximateReceiveCount": "1",
+                "SentTimestamp": "1523232000000",
+                "SenderId": "123456789012",
+                "ApproximateFirstReceiveTimestamp": "1523232000001"
+            },
+            "messageAttributes": {},
+            "md5OfBody": "7b270e59b47ff90a553787216d55d91d",
+            "eventSource": "aws:sqs",
+            "eventSourceARN": "arn:aws:sqs:us-west-2:123456789012:MyQueue",
+            "awsRegion": "us-west-2"
+        }
+    ]
+}

sample-apps/java-events/pom.xml

@@ -20,7 +20,7 @@
     <dependency>
       <groupId>com.amazonaws</groupId>
       <artifactId>aws-lambda-java-events</artifactId>
-      <version>3.9.0</version>
+      <version>3.11.0</version>
     </dependency>
     <dependency>
       <groupId>com.google.code.gson</groupId>

sample-apps/java-events/src/main/java/example/HandlerSQS.java

@@ -0,0 +1,34 @@
+package example;
+
+import com.amazonaws.services.lambda.runtime.Context;
+import com.amazonaws.services.lambda.runtime.RequestHandler;
+import com.amazonaws.services.lambda.runtime.events.SQSEvent;
+import com.amazonaws.services.lambda.runtime.events.SQSEvent.SQSMessage;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+// Handler value: example.HandlerSQS
+public class HandlerSQS implements RequestHandler<SQSEvent, String>{
+  private static final Logger logger = LoggerFactory.getLogger(HandlerSQS.class);
+  Gson gson = new GsonBuilder().setPrettyPrinting().create();
+  @Override
+  public String handleRequest(SQSEvent event, Context context)
+  {
+    String response = new String("200 OK");
+    // log execution details
+    logger.info("ENVIRONMENT VARIABLES: {}", gson.toJson(System.getenv()));
+    logger.info("CONTEXT: {}", gson.toJson(context));
+    logger.info("EVENT: {}", gson.toJson(event));
+    // process event
+    for(SQSMessage msg : event.getRecords()){
+      logger.info(msg.getBody());
+    }
+    // log execution details
+    Util.logEnvironment(event, context, gson);
+    return response;
+  }
+}

sample-apps/java-events/template.yml

@@ -6,7 +6,7 @@ Resources:
     Type: AWS::Serverless::Function
     Properties:
       CodeUri: build/distributions/java-events.zip
-      Handler: example.Handler
+      Handler: example.HandlerSQS
       Runtime: java8
       Description: Java function
       MemorySize: 512