Increase max listeners on stream to 1000

platy · platy · commit 50f9202acdd5 · 2015-10-02T15:25:34.000+02:00
diff --git a/lib/client.js b/lib/client.js
@@ -245,6 +245,9 @@ MqttClient.prototype._setupStream = function () {
   // Echo connection errors
   parser.on('error', this.emit.bind(this, 'error'));
 
+  // many drain listeners are needed for qos 1 callbacks if the connection is intermittent
+  this.stream.setMaxListeners(1000);
+
   clearTimeout(this.connackTimer);
   this.connackTimer = setTimeout(function () {
     that._cleanUp(true);
