Amend Java: lambda-function-sqs-report-batch-item-failures #234

integration-sns-to-lambda/example.mjs

@@ -0,0 +1,21 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+export const handler = async (event, context) => {
+    for (const record of event.Records) {
+      await processMessageAsync(record);
+    }
+    console.info("done");
+  };
+
+  async function processMessageAsync(record) {
+    try {
+      const message = JSON.stringify(record.Sns.Message);
+      console.log(`Processed message ${message}`);
+      await Promise.resolve(1); //Placeholder for actual async work
+    } catch (err) {
+      console.error("An error occurred");
+      throw err;
+    }
+  }
+
+

lambda-function-sqs-report-batch-item-failures/example.java

@@ -17,6 +17,7 @@ public SQSBatchResponse handleRequest(SQSEvent sqsEvent, Context context) {
          for (SQSEvent.SQSMessage message : sqsEvent.getRecords()) {
              try {
                  //process your message
+                 System.out.println("Processed message: " + message.getBody());
              } catch (Exception e) {
                  //Add failed message identifier to the batchItemFailures list
                  batchItemFailures.add(new SQSBatchResponse.BatchItemFailure(message.getMessageId()));

lambda-function-sqs-report-batch-item-failures/example.py

@@ -8,7 +8,7 @@ def lambda_handler(event, context):
 
         for record in event["Records"]:
             try:
-                # process message
+                print(f"Processed message: {record['body']}")
             except Exception as e:
                 batch_item_failures.append({"itemIdentifier": record['messageId']})