do not subscribe closed clients

moscajs · Aug 25, 2024 · a191366 · a191366
1 parent 9c93183
commit a191366
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/lib/handlers/subscribe.js b/lib/handlers/subscribe.js
@@ -155,6 +155,13 @@ function addSubs (sub, done) {
     func = blockDollarSignTopics(func)
   }
 
+  if (client.closed || client.broker.closed) {
+    // a hack, sometimes client.close() or broker.close() happened
+    // before authenticate() comes back
+    // we don't continue subscription here
+    return
+  }
+
   if (!client.subscriptions[topic]) {
     client.subscriptions[topic] = new Subscription(qos, func, rh, rap, nl)
     broker.subscribe(topic, func, done)