From e7447cf1e320e93753a58e7eb117f05ca0eda754 Mon Sep 17 00:00:00 2001
From: Koen Kanters <koenkanters94@gmail.com>
Date: Tue, 30 Nov 2021 19:05:28 +0100
Subject: [PATCH] Another attempt to fix
 https://github.com/Koenkk/zigbee2mqtt/issues/9822

---
 lib/mqtt.ts       | 3 ++-
 test/stub/mqtt.js | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/lib/mqtt.ts b/lib/mqtt.ts
index a5bc7fd3..e1cc2ac9 100644
--- a/lib/mqtt.ts
+++ b/lib/mqtt.ts
@@ -69,7 +69,8 @@ export default class MQTT {
 
         return new Promise((resolve, reject) => {
             this.client = mqtt.connect(mqttSettings.server, options);
-            this.client.setMaxListeners(0);
+            // @ts-ignore https://github.com/Koenkk/zigbee2mqtt/issues/9822
+            this.client.stream.setMaxListeners(0);
 
             const onConnect = this.onConnect;
             this.client.on('connect', async () => {
diff --git a/test/stub/mqtt.js b/test/stub/mqtt.js
index 9c60a381..c47d177b 100644
--- a/test/stub/mqtt.js
+++ b/test/stub/mqtt.js
@@ -6,7 +6,7 @@ const mock = {
     subscribe: jest.fn(),
     reconnecting: false,
     on: jest.fn(),
-    setMaxListeners: jest.fn(),
+    stream: {setMaxListeners: jest.fn()}
 };
 
 const mockConnect = jest.fn().mockReturnValue(mock);