From 3ea454c7ed03bffcf89ad27dfe5e38117481c3d4 Mon Sep 17 00:00:00 2001 From: Davidson Gomes Date: Thu, 31 Aug 2023 17:01:09 -0300 Subject: [PATCH] fix: create rabbitmq queues on set config --- src/libs/amqp.server.ts | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/libs/amqp.server.ts b/src/libs/amqp.server.ts index 272577d9..21357257 100644 --- a/src/libs/amqp.server.ts +++ b/src/libs/amqp.server.ts @@ -43,6 +43,9 @@ export const getAMQP = (): amqp.Channel | null => { }; export const initQueues = (instanceName: string, events: string[]) => { + console.log('initQueues', instanceName, events); + if (!events.length) return; + const queues = events.map((event) => { return `${event.replace(/_/g, '.').toLowerCase()}`; });