From f6cd10558de9655a179e809f61aadf486e21ea3f Mon Sep 17 00:00:00 2001 From: hzmi Date: Fri, 23 Feb 2024 17:25:56 +0000 Subject: [PATCH] fix: remove prefetch --- services/kanao-cache/src/Structures/KanaoCache.ts | 1 - 1 file changed, 1 deletion(-) diff --git a/services/kanao-cache/src/Structures/KanaoCache.ts b/services/kanao-cache/src/Structures/KanaoCache.ts index a4981a45..6cdfc76a 100644 --- a/services/kanao-cache/src/Structures/KanaoCache.ts +++ b/services/kanao-cache/src/Structures/KanaoCache.ts @@ -38,7 +38,6 @@ export class KanaoCache extends EventEmitter { public async setupAmqp(channel: Channel): Promise { await channel.assertExchange(RabbitMQ.GATEWAY_EXCHANGE, "topic", { durable: false }); - await channel.prefetch(1); // Used for receiving receive events from the gateway const routingKey = new RoutedQueue(GatewayExchangeRoutes.RECEIVE, clientId, "cache");