Fixed

Habib23me · Jul 12, 2022 · 471a13e · 471a13e
1 parent c5140d5
commit 471a13e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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) {