From c24eb37868ef0c61de8cad63550c0f0805811c27 Mon Sep 17 00:00:00 2001
From: Tereza Tomcova <tereza.tomcova@gmail.com>
Date: Tue, 9 Apr 2024 16:40:27 +0200
Subject: [PATCH] Set the max listener limit to 1000 for `RheaConnection`

---
 lib/connection.ts | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/lib/connection.ts b/lib/connection.ts
index 0a742d8..456655b 100644
--- a/lib/connection.ts
+++ b/lib/connection.ts
@@ -202,6 +202,8 @@ export declare interface Connection {
   on(event: ConnectionEvents, listener: OnAmqpEvent): this;
 }
 
+const maxListenerLimit = 1000;
+
 /**
  * Describes the AMQP Connection.
  * @class Connection
@@ -256,6 +258,10 @@ export class Connection extends Entity {
     this.options.operationTimeoutInSeconds = options?.operationTimeoutInSeconds ?? defaultOperationTimeoutInSeconds;
 
     this._initializeEventListeners();
+
+    // Set max listeners on the connection to 1000 because Session and Link add their own listeners
+    // and the default value of 10 in NodeJS is too low.
+    this._connection.setMaxListeners(maxListenerLimit);
   }
 
   /**