Skip to content

Commit 7bc4c7b

Browse files
committed
ajustes rabbitmq
1 parent 79189ac commit 7bc4c7b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/libs/amqp.server.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,11 +67,11 @@ export const initQueues = (instanceName: string, events: string[]) => {
6767
const amqp = getAMQP();
6868

6969
const rabbitMode = rabbitConfig.MODE || 'isolated';
70-
let exchangeName = rabbitConfig.EXCHANGE_NAME ?? 'evolution_exchange';
70+
const exchangeName = rabbitConfig.EXCHANGE_NAME ?? 'evolution_exchange';
7171

7272
const receivedEvents = events.map(parseEvtName);
7373
if (rabbitMode === 'isolated') {
74-
exchangeName = instanceName ?? 'evolution_exchange';
74+
// exchangeName = instanceName ?? 'evolution_exchange';
7575

7676
receivedEvents.forEach((event) => {
7777
amqp.assertExchange(exchangeName, 'topic', {

0 commit comments

Comments
 (0)