fix: Fix calling processMessage in handleSqsResponse

bbc · Mar 18, 2024 · 3a292f2 · 3a292f2
1 parent 6b7303e
commit 3a292f2
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/consumer.ts b/src/consumer.ts
@@ -312,7 +312,11 @@ export class Consumer extends TypedEventEmitter {
       if (this.handleMessageBatch) {
         await this.processMessageBatch(response.Messages);
       } else {
-        await Promise.all(response.Messages.map(this.processMessage));
+        await Promise.all(
+          response.Messages.map((message: Message) =>
+            this.processMessage(message),
+          ),
+        );
       }
 
       this.emit("response_processed");