fix(rabbitmq): 🐛 missing await

bcnmy · Jan 24, 2025 · a581728 · a581728
1 parent ae47a2d
commit a581728
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/relayer/consumer/BundlerConsumer.ts b/src/relayer/consumer/BundlerConsumer.ts
@@ -71,7 +71,7 @@ export class BundlerConsumer
       topLog.info(`BundlerConsumer.onMessageReceived`);
 
       try {
-        this.queue.ack(msg);
+        await this.queue.ack(msg);
       } catch (err) {
         topLog.error({ err }, `BundlerConsumer.onMessageReceived:: Error while acknowledging message`);
       }

diff --git a/src/relayer/retry-transaction-service/EVMRetryTransactionService.ts b/src/relayer/retry-transaction-service/EVMRetryTransactionService.ts
@@ -75,7 +75,7 @@ export class EVMRetryTransactionService
       );
 
       try {
-        this.queue.ack(msg);
+        await this.queue.ack(msg);
       } catch (err) {
         log.error({ err }, `EVMRetryTransactionService.onMessageReceived:: Error while acknowledging message`);
       }