Merge pull request #110 from the-ress/max-listener-limit

Set the max listener limit to 1000 for `RheaConnection`
amqp · May 2, 2024 · cd5c42c · cd5c42c
2 parents e37362a + c24eb37
commit cd5c42c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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);
   }
 
   /**