Fixed MQTT test.

moscajs · Apr 17, 2014 · 94062d3 · 94062d3
1 parent 7ae87ff
commit 94062d3
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 6 deletions.
diff --git a/test/common.js b/test/common.js
@@ -95,6 +95,7 @@ var mosca = require("mosca");
 
 global.mqttServer = new mosca.Server({
   port: 5883,
+  stats: false,
   logger: {
     level: "fatal"
   }

diff --git a/test/mqtt_ascoltatore_spec.js b/test/mqtt_ascoltatore_spec.js
@@ -29,15 +29,13 @@ describeAscoltatore("MQTT", function() {
       }
     ]);
   });
-  
+
   it("should publish with options", function(done) {
     var that = this;
-    that.instance.subscribe("hello/*", function(topic, value, options) {
-      expect(value).to.equal("42");
-      expect(options.qos).to.equal(0);
+    mqttServer.once('published', function(packet) {
+      expect(packet.qos).to.eql(0);
       done();
-    }, function () {
-      that.instance.publish("hello/123", "42", { qos: 0 });
     });
+    that.instance.publish("hello/123", "42", { qos: 0 });
   });
 });