diff --git a/src/libs/amqp.server.ts b/src/libs/amqp.server.ts index 759d3d20..850f4106 100644 --- a/src/libs/amqp.server.ts +++ b/src/libs/amqp.server.ts @@ -67,11 +67,11 @@ export const initQueues = (instanceName: string, events: string[]) => { const amqp = getAMQP(); const rabbitMode = rabbitConfig.MODE || 'isolated'; - let exchangeName = rabbitConfig.EXCHANGE_NAME ?? 'evolution_exchange'; + const exchangeName = rabbitConfig.EXCHANGE_NAME ?? 'evolution_exchange'; const receivedEvents = events.map(parseEvtName); if (rabbitMode === 'isolated') { - exchangeName = instanceName ?? 'evolution_exchange'; + // exchangeName = instanceName ?? 'evolution_exchange'; receivedEvents.forEach((event) => { amqp.assertExchange(exchangeName, 'topic', {