From 826e8188024ae6c4f676c22b5b628a7ca0a4ff0f Mon Sep 17 00:00:00 2001 From: Davidson Gomes Date: Fri, 8 Mar 2024 13:48:38 -0300 Subject: [PATCH] test --- src/libs/amqp.server.ts | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/libs/amqp.server.ts b/src/libs/amqp.server.ts index 3c7c7098..b580372e 100644 --- a/src/libs/amqp.server.ts +++ b/src/libs/amqp.server.ts @@ -73,12 +73,12 @@ export const initQueues = (instanceName: string, events: string[]) => { if (rabbitMode === 'isolated') { exchangeName = instanceName ?? 'evolution_exchange'; - receivedEvents.forEach((event) => { - amqp.assertExchange(exchangeName, 'topic', { - durable: true, - autoDelete: false, - }); + amqp.assertExchange(exchangeName, 'topic', { + durable: true, + autoDelete: false, + }); + receivedEvents.forEach((event) => { const queueName = `${instanceName}.${event}`; amqp.assertQueue(queueName, { durable: true,