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

fix: update RabbitMQ frame_max parameter for 4.1+ compatibility

Browse Source 
Updates the minimum frame_max value from 4096 to 8192 to meet the requirements
of RabbitMQ 4.1+ servers. This resolves connection failures with newer RabbitMQ
versions while maintaining backwards compatibility with older versions.
This commit is contained in:
Thiago Souza 2025-05-25 02:42:51 -03:00
parent 427c994993
commit 3297364c10
3 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.env.example
View File

@ -47,6 +47,7 @@ DATABASE_DELETE_MESSAGE=true
RABBITMQ_ENABLED=false RABBITMQ_ENABLED=false
RABBITMQ_URI=amqp://localhost RABBITMQ_URI=amqp://localhost
RABBITMQ_EXCHANGE_NAME=evolution RABBITMQ_EXCHANGE_NAME=evolution
RABBITMQ_FRAME_MAX=8192
# Global events - By enabling this variable, events from all instances are sent in the same event queue. # Global events - By enabling this variable, events from all instances are sent in the same event queue.
RABBITMQ_GLOBAL_ENABLED=false RABBITMQ_GLOBAL_ENABLED=false
# Prefix key to queue name # Prefix key to queue name

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

@ -21,9 +21,21 @@ 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 frameMax = configService.get<Rabbitmq>('RABBITMQ').FRAME_MAX;
const rabbitmqExchangeName = configService.get<Rabbitmq>('RABBITMQ').EXCHANGE_NAME; const rabbitmqExchangeName = configService.get<Rabbitmq>('RABBITMQ').EXCHANGE_NAME;
amqp.connect(uri, (error, connection) => { const url = new URL(uri);
const connectionOptions = {
protocol: url.protocol.slice(0, -1),
hostname: url.hostname,
port: url.port || 5672,
username: url.username || 'guest',
password: url.password || 'guest',
vhost: url.pathname.slice(1) || '/',
frameMax: frameMax
};
amqp.connect(connectionOptions, (error, connection) => {
if (error) { if (error) {
reject(error); reject(error);

2
src/config/env.config.ts
View File

@ -94,6 +94,7 @@ export type EventsRabbitmq = {
export type Rabbitmq = { export type Rabbitmq = {
ENABLED: boolean; ENABLED: boolean;
URI: string; URI: string;
FRAME_MAX: number;
EXCHANGE_NAME: string; EXCHANGE_NAME: string;
GLOBAL_ENABLED: boolean; GLOBAL_ENABLED: boolean;
EVENTS: EventsRabbitmq; EVENTS: EventsRabbitmq;
@ -359,6 +360,7 @@ export class ConfigService {
PREFIX_KEY: process.env?.RABBITMQ_PREFIX_KEY || 'evolution', PREFIX_KEY: process.env?.RABBITMQ_PREFIX_KEY || 'evolution',
EXCHANGE_NAME: process.env?.RABBITMQ_EXCHANGE_NAME || 'evolution_exchange', EXCHANGE_NAME: process.env?.RABBITMQ_EXCHANGE_NAME || 'evolution_exchange',
URI: process.env.RABBITMQ_URI || '', URI: process.env.RABBITMQ_URI || '',
FRAME_MAX: Number.parseInt(process.env.RABBITMQ_FRAME_MAX) || 8192,
EVENTS: { EVENTS: {
APPLICATION_STARTUP: process.env?.RABBITMQ_EVENTS_APPLICATION_STARTUP === 'true', APPLICATION_STARTUP: process.env?.RABBITMQ_EVENTS_APPLICATION_STARTUP === 'true',
INSTANCE_CREATE: process.env?.RABBITMQ_EVENTS_INSTANCE_CREATE === 'true', INSTANCE_CREATE: process.env?.RABBITMQ_EVENTS_INSTANCE_CREATE === 'true',