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()}`; });