feat: add error when queue is not getting emptied properly

winbergoscar0 · Nov 8, 2023 · b950415 · b950415
1 parent 199ab56
commit b950415
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/utils/rabbitmq.ts b/src/utils/rabbitmq.ts
@@ -49,6 +49,12 @@ export class RabbitMq implements MoveerRabbitMq {
       durable: true,
     });
 
+    this.rabbitMqChannel.checkQueue(queue, (err, result) => {
+      if (result.messageCount > 100) {
+        reportMoveerError(`Queue ${queue} is getting full!!!!`);
+      }
+    });
+
     this.rabbitMqChannel.sendToQueue(
       queue,
       Buffer.from(JSON.stringify(rabbitMqMessage)),