chore: use exchange

NezuChan · Feb 22, 2024 · c7e993c · c7e993c
1 parent 6a37bb6
commit c7e993c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/services/kanao-cache/src/Structures/KanaoCache.ts b/services/kanao-cache/src/Structures/KanaoCache.ts
@@ -33,7 +33,9 @@ export class KanaoCache extends EventEmitter {
 
     public async setupAmqp(channel: Channel): Promise<void> {
         await channel.prefetch(1);
+        await channel.assertExchange("nezu-gateway.cache", "direct", { durable: true });
         const { queue } = await channel.assertQueue("kanao-cache.receive", { durable: true });
+        await channel.bindQueue(queue, "nezu-gateway.cache", clientId);
 
         this.logger.info("Successfully bind to cache queue!");
 

diff --git a/services/kanao-gateway/src/Structures/KanaoGateway.ts b/services/kanao-gateway/src/Structures/KanaoGateway.ts
@@ -149,9 +149,6 @@ export class NezuGateway extends EventEmitter {
         const amqpChannel = createAmqpChannel(amqp, {
             setup: async (channel: Channel) => {
                 await channel.assertExchange("nezu-gateway.cache", "direct", { durable: true });
-                await channel.assertQueue("kanao-cache.receive", { durable: true });
-                await channel.bindQueue("kanao-cache.receive", "nezu-gateway.cache", clientId);
-
                 await channel.assertExchange(RabbitMQ.GATEWAY_QUEUE_STATS, "topic", { durable: false });
 
                 const { queue } = await channel.assertQueue("", { exclusive: true });