From 471a13ebe219473bc5504a08e158698986bda8d4 Mon Sep 17 00:00:00 2001
From: Habib <habib23me@gmail.com>
Date: Tue, 12 Jul 2022 16:57:59 +0300
Subject: [PATCH] Fixed

---
 src/message-broker.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/message-broker.ts b/src/message-broker.ts
index 134fad6..e06b4d9 100644
--- a/src/message-broker.ts
+++ b/src/message-broker.ts
@@ -101,7 +101,7 @@ export abstract class MessageBroker {
 
     this.queues[queue] = [handler];
 
-    this.channel.prefetch(1);
+    // this.channel.prefetch(1);
     this.channel.consume(queue, async (msg: any) => {
       console.log(`[ ${new Date()} ] Message received: ${JSON.stringify(JSON.parse(msg.content.toString('utf8')))}`);
       if (msg !== null) {