fi: assert non durable queue

NezuChan · Feb 23, 2024 · 8b047ff · 8b047ff
1 parent 1357f5a
commit 8b047ff
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/packages/core/src/Structures/Client.ts b/packages/core/src/Structures/Client.ts
@@ -72,7 +72,7 @@ export class Client extends EventEmitter {
 
         const routing = new RoutedQueue(GatewayExchangeRoutes.DISPATCH, this.clientId, this.options.instanceName);
 
-        const { queue } = await channel.assertQueue(routing.queue);
+        const { queue } = await channel.assertQueue(routing.queue, { durable: false });
         await this.bindQueue(channel, RabbitMQ.GATEWAY_EXCHANGE, routing);
 
         await channel.consume(queue, message => {

diff --git a/services/kanao-cache/src/Structures/KanaoCache.ts b/services/kanao-cache/src/Structures/KanaoCache.ts
@@ -42,7 +42,7 @@ export class KanaoCache extends EventEmitter {
 
         // Used for receiving receive events from the gateway
         const routingKey = new RoutedQueue(GatewayExchangeRoutes.RECEIVE, clientId, "cache");
-        const { queue } = await channel.assertQueue(routingKey.queue);
+        const { queue } = await channel.assertQueue(routingKey.queue, { durable: false });
         await channel.bindQueue(queue, "kanao-gateway", routingKey.key);
         await channel.consume(queue, message => {
             if (message) {