fix: Refactor message processing in SQSHandler

Coaktion · Sep 26, 2024 · 4ecea98 · 4ecea98
1 parent d9abd98
commit 4ecea98
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/ext/sqs/handlers.ts b/src/ext/sqs/handlers.ts
@@ -70,12 +70,13 @@ export class SQSHandler extends BaseSQS {
       logging.info(
         `Received ${messages.length} messages from queue ${this.provider.queueName}`
       );
-      messages.forEach((message: any) => {
-        this.processMessage(message);
-      });
+      const promises = messages.map((message: any) =>
+        this.processMessage(message)
+      );
+      await Promise.all(promises);
     }
 
-    this.callPoll();
+    await this.callPoll();
   }
 
   async callPoll(): Promise<void> {