diff --git a/src/libs/amqp.server.ts b/src/libs/amqp.server.ts index fc95b33c..c861916b 100644 --- a/src/libs/amqp.server.ts +++ b/src/libs/amqp.server.ts @@ -27,6 +27,7 @@ export const initAMQP = () => { channel.assertExchange(exchangeName, 'topic', { durable: true, autoDelete: false, + assert: true, }); amqpChannel = channel; @@ -43,7 +44,7 @@ export const getAMQP = (): amqp.Channel | null => { }; export const initQueues = (instanceName: string, events: string[]) => { - if (!events || !events.length) return; + if (!instanceName || !events || !events.length) return; const queues = events.map((event) => { return `${event.replace(/_/g, '.').toLowerCase()}`; @@ -56,6 +57,7 @@ export const initQueues = (instanceName: string, events: string[]) => { amqp.assertExchange(exchangeName, 'topic', { durable: true, autoDelete: false, + assert: true, }); const queueName = `${instanceName}.${event}`; @@ -89,6 +91,7 @@ export const removeQueues = (instanceName: string, events: string[]) => { amqp.assertExchange(exchangeName, 'topic', { durable: true, autoDelete: false, + assert: true, }); const queueName = `${instanceName}.${event}`; diff --git a/src/whatsapp/services/whatsapp.service.ts b/src/whatsapp/services/whatsapp.service.ts index 7f247b0d..2f709e19 100644 --- a/src/whatsapp/services/whatsapp.service.ts +++ b/src/whatsapp/services/whatsapp.service.ts @@ -779,6 +779,7 @@ export class WAStartupService { amqp.assertExchange(exchangeName, 'topic', { durable: true, autoDelete: false, + assert: true, }); const queueName = `${this.instanceName}.${event}`;