diff --git a/.gitignore b/.gitignore index aab1692..61cad6b 100644 --- a/.gitignore +++ b/.gitignore @@ -1,3 +1,4 @@ /node_modules/ *.lock /archive/ +/.yalc/ diff --git a/.npmignore b/.npmignore index 480e0f5..fa9b097 100644 --- a/.npmignore +++ b/.npmignore @@ -4,3 +4,4 @@ test/ testing/ archive/ example/ +.yalc diff --git a/package.json b/package.json index f463da7..c7cd285 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@uci/mqtt", - "version": "0.3.0", + "version": "0.3.1", "description": "mqtt client with UCI json packet payloads", "main": "src", "scripts": { diff --git a/src/mqtt.js b/src/mqtt.js index 49e22e4..c96f494 100644 --- a/src/mqtt.js +++ b/src/mqtt.js @@ -272,7 +272,11 @@ class MQTTClient extends EventEmitter { return payload } _listen() { - log.debug({method:'_listen', line:147, msg:`listening for incoming mqtt packets from broker on topics ${this.topics}`}) + + const msg = `listening for incoming mqtt packets from broker on topics ${this.topics}` + log.debug({method:'_listen', line:147, msg:msg}) + + this.emit('socket',{state:'listening', msg:msg}) this.mqtt.on('message', messageProcess.bind(this))