Merge branch 'master' of https://github.com/roccomuso/MQTT.js into roccomuso-master

mcollina · mcollina · commit 4d0839316b87 · 2016-09-01T17:26:09.000+02:00
diff --git a/bin/pub.js b/bin/pub.js
@@ -15,7 +15,15 @@ var mqtt      = require('../')
 function send(args) {
   var client = mqtt.connect(args);
   client.on('connect', function() {
-    client.publish(args.topic, args.message, args);
+    client.publish(args.topic, args.message, args, function(err) {
+      if (err) {
+        console.warn(err);
+      }
+      client.end();
+    });
+  });
+  client.on('error', function(err){
+    console.warn(err);
     client.end();
   });
 }
diff --git a/bin/sub.js b/bin/sub.js
@@ -106,6 +106,11 @@ function start(args) {
       console.log(payload.toString())
     }
   });
+
+  client.on('error', function(err){
+    console.warn(err);
+    client.end();
+  });
 }
 
 module.exports = start;

Original file line number	Diff line number	Diff line change
`@@ -106,6 +106,11 @@ function start(args) {`
`106`	`106`	`console.log(payload.toString())`
`107`	`107`	`}`
`108`	`108`	`});`
	`109`	`+`
	`110`	`+ client.on('error', function(err){`
	`111`	`+ console.warn(err);`
	`112`	`+ client.end();`
	`113`	`+ });`
`109`	`114`	`}`
`110`	`115`
`111`	`116`	`module.exports = start;`