Allow specification of a reconnect period

Adam Rudd · Adam Rudd · commit f6c2d62ce2b5 · 2013-06-12T10:53:46.000+02:00
diff --git a/lib/client.js b/lib/client.js
@@ -12,7 +12,8 @@ var Connection = require('./connection')
 var defaultConnectOptions = {
   keepalive: 10,
   protocolId: 'MQIsdp',
-  protocolVersion: 3
+  protocolVersion: 3,
+  reconnectPeriod: 1000
 };
 
 var defaultId = function() {
@@ -159,7 +160,7 @@ function MqttClient(stream, options) {
     if (!that.reconnectTimer) {
       that.reconnectTimer = setInterval(function () {
         that._reconnect();
-      }, 1000);
+      }, that.options.reconnectPeriod);
     }
   });
 
diff --git a/test/client.js b/test/client.js
@@ -667,5 +667,29 @@ describe('MqttClient', function () {
         done();
       });
     });
+
+    it('should allow specification of a reconnect period', function(done) {
+      this.timeout(2200);
+      var client = createClient(port, {reconnectPeriod: 2000})
+        , reconnect = false;
+
+      var start = process.hrtime()
+        , end;
+
+      client.on('connect', function () {
+        if (!reconnect) {
+          client.stream.end();
+          reconnect = true;
+        } else {
+          end = process.hrtime(start);
+          if (end[0] === 2) {
+            // Connected in about 2 seconds, that's good enough
+            done();
+          } else {
+            done(new Error('Strange reconnect period'));
+          }
+        }
+      });
+    });
   });
 });
