fix: try dont use prefetch

NezuChan · Feb 23, 2024 · 7438e33 · 7438e33
1 parent df77eff
commit 7438e33
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/services/kanao-cache/src/Structures/KanaoCache.ts b/services/kanao-cache/src/Structures/KanaoCache.ts
@@ -35,7 +35,7 @@ export class KanaoCache extends EventEmitter {
     }
 
     public async setupAmqp(channel: Channel): Promise<void> {
-        await channel.prefetch(1);
+        // await channel.prefetch(1);
         await channel.assertExchange(RabbitMQ.GATEWAY_QUEUE_SEND, "direct", { durable: true });
         await channel.assertExchange("nezu-gateway.cache", "direct", { durable: true });
         const { queue } = await channel.assertQueue("kanao-cache.receive", { durable: true });