NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-07-14 09:51:24 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

Use exchange name from .env

Browse Source
This commit is contained in:
Judson Cairo 2024-09-04 17:09:42 -03:00
parent 2784b907b0
commit 65debe5a95
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/api/integrations/event/rabbitmq/rabbitmq.controller.ts
View File

@ -21,6 +21,7 @@ export class RabbitmqController extends EventController implements EventControll
await new Promise<void>((resolve, reject) => { await new Promise<void>((resolve, reject) => {
const uri = configService.get<Rabbitmq>('RABBITMQ').URI; const uri = configService.get<Rabbitmq>('RABBITMQ').URI;
const rabbitmqExchangeName = configService.get<Rabbitmq>('RABBITMQ').EXCHANGE_NAME;
amqp.connect(uri, (error, connection) => { amqp.connect(uri, (error, connection) => {
if (error) { if (error) {
@ -36,7 +37,7 @@ export class RabbitmqController extends EventController implements EventControll
return; return;
} }
const exchangeName = 'evolution_exchange'; const exchangeName = rabbitmqExchangeName;
channel.assertExchange(exchangeName, 'topic', { channel.assertExchange(exchangeName, 'topic', {
durable: true, durable: true,
@ -81,6 +82,7 @@ export class RabbitmqController extends EventController implements EventControll
const rabbitmqLocal = instanceRabbitmq?.events; const rabbitmqLocal = instanceRabbitmq?.events;
const rabbitmqGlobal = configService.get<Rabbitmq>('RABBITMQ').GLOBAL_ENABLED; const rabbitmqGlobal = configService.get<Rabbitmq>('RABBITMQ').GLOBAL_ENABLED;
const rabbitmqEvents = configService.get<Rabbitmq>('RABBITMQ').EVENTS; const rabbitmqEvents = configService.get<Rabbitmq>('RABBITMQ').EVENTS;
const rabbitmqExchangeName = configService.get<Rabbitmq>('RABBITMQ').EXCHANGE_NAME;
const we = event.replace(/[.-]/gm, '_').toUpperCase(); const we = event.replace(/[.-]/gm, '_').toUpperCase();
const logEnabled = configService.get<Log>('LOG').LEVEL.includes('WEBHOOKS'); const logEnabled = configService.get<Log>('LOG').LEVEL.includes('WEBHOOKS');
@ -96,7 +98,7 @@ export class RabbitmqController extends EventController implements EventControll
if (instanceRabbitmq?.enabled && this.amqpChannel) { if (instanceRabbitmq?.enabled && this.amqpChannel) {
if (Array.isArray(rabbitmqLocal) && rabbitmqLocal.includes(we)) { if (Array.isArray(rabbitmqLocal) && rabbitmqLocal.includes(we)) {
const exchangeName = instanceName ?? 'evolution_exchange'; const exchangeName = instanceName ?? rabbitmqExchangeName;
let retry = 0; let retry = 0;
@ -141,7 +143,7 @@ export class RabbitmqController extends EventController implements EventControll
} }
if (rabbitmqGlobal && rabbitmqEvents[we] && this.amqpChannel) { if (rabbitmqGlobal && rabbitmqEvents[we] && this.amqpChannel) {
const exchangeName = 'evolution_exchange'; const exchangeName = rabbitmqExchangeName;
let retry = 0; let retry = 0;
@ -186,6 +188,7 @@ export class RabbitmqController extends EventController implements EventControll
private async initGlobalQueues(): Promise<void> { private async initGlobalQueues(): Promise<void> {
this.logger.info('Initializing global queues'); this.logger.info('Initializing global queues');
const rabbitmqExchangeName = configService.get<Rabbitmq>('RABBITMQ').EXCHANGE_NAME;
const events = configService.get<Rabbitmq>('RABBITMQ').EVENTS; const events = configService.get<Rabbitmq>('RABBITMQ').EVENTS;
if (!events) { if (!events) {
@ -200,7 +203,7 @@ export class RabbitmqController extends EventController implements EventControll
if (events[event] === false) return; if (events[event] === false) return;
const queueName = `${event.replace(/_/g, '.').toLowerCase()}`; const queueName = `${event.replace(/_/g, '.').toLowerCase()}`;
const exchangeName = 'evolution_exchange'; const exchangeName = rabbitmqExchangeName;
this.amqpChannel.assertExchange(exchangeName, 'topic', { this.amqpChannel.assertExchange(exchangeName, 'topic', {
durable: true, durable: true,