EventEmitter memory leak detected. (esl-lite)

[samuelOEbanqo]

As recommended, I am using the esl-lite version. However, in the process of auto-reconnecting I am getting the following error.

{"level":50,"time":1754903969228,"pid":42,"hostname":"xxxxxx","module":"FreeSwitchSocket","ref":"xxxx","attempt":3,"retry":200,"error":{"errno":-104,"code":"ECONNRESET","syscall":"read"},"code":"ECONNRESET","msg":"Socket failed"}
2025-08-11T09:19:29.498486228Z {"level":30,"time":1754903969496,"pid":42,"hostname":"xxxxxxx","module":"FreeSwitchSocket","ref":"xxxxxxx","attempt":4,"retry":200,"msg":"Connected"}
2025-08-11T09:19:29.727779270Z (node:42) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 drain listeners added to [Socket]. Use emitter.setMaxListeners() to increase limit

[shimaore]

Hi @samuelOEbanqo ! Thank you for your report.

The drain-related message would happen if the module is pushing messages to FreeSwitch faster than FreeSwitch can read the TCP socket. Assuming this is related to the reconnection (i.e. you have a single socket open), this would indicate that too many operations are pending at reconnection time.

Do you have a short example Node.js script to reproduce the issue (I assume this can be tested by restarting FreeSwitch)?

[samuelOEbanqo]

@shimaore , Thank you very much for your quick response. Please find the connect logic I am using below:

const port = parseInt(process.env.FREESWITCH_INBOUND_PORT || "8021");
console.log('[PBX]: Attempting to Connect to FreeSwitch on ', process.env.FREESWITCH_DOMAIN, port);
try {
    this.client = new FreeSwitchClient({
        host: process.env.FREESWITCH_DOMAIN!,
        port,
        password: process.env.FREESWITCH_PASSWORD!,
        logger: pino(),
    });

    this.client.on("CHANNEL_PARK", this.handleEvents);
    this.client.on("CHANNEL_ANSWER", this.handleEvents);
    this.client.on("CHANNEL_HANGUP", this.handleEvents);
    this.client.on("CHANNEL_HANGUP_COMPLETE", this.handleEvents);
    this.client.on("CHANNEL_BRIDGE", this.handleEvents);
    this.client.on("CHANNEL_UNBRIDGE", this.handleEvents);
    this.client.on("DTMF", this.handleEvents);
    this.STATUS = STATUS.UP;
} catch (error) {
    this.STATUS = STATUS.DOWN;
    console.log("[PBX]: Connection Error  ", error);
}

this.handleEvents is simply a method that publish the event to RabbitMQ