Merge pull request #461 from stableShip/catch-persistence-error

Added exception catch for invalid persistence
moscajs · Apr 26, 2016 · a0324d4 · a0324d4
2 parents 37497cf + 05f0d36
commit a0324d4
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 1 deletion.
diff --git a/lib/server.js b/lib/server.js
@@ -229,7 +229,12 @@ function Server(opts, callback) {
       that.emit("ready");
       done(null);
     }
-  ]);
+  ], function(err, results){
+    if(err) {
+      callback(err)
+    }
+  });
+
 
   that.on("clientConnected", function(client) {
     if(that.modernOpts.publishNewClient) {

diff --git a/test/server.js b/test/server.js
@@ -149,6 +149,23 @@ describe("mosca.Server", function() {
     });
   });
 
+  it("should fail if persistence can not connect", function (done) {
+    var newSettings = moscaSettings();
+
+    newSettings.persistence = {
+      factory: mosca.persistence.Mongo,
+      url: "mongodb://someUrlCannotConnect"
+    };
+
+    var server = new mosca.Server(newSettings, function (err) {
+      if (err instanceof Error) {
+        done();
+      } else {
+        expect().fail("new mosca.Server should fail");
+      }
+    });
+  });
+
   describe("timers", function() {
     var clock;
 
@@ -797,4 +814,6 @@ describe("mosca.Server - MQTT backend", function() {
       }
     });
   });
+
+
 });