lib/mqttTool.js
@@ -113,28 +113,6 @@ }) } //消息处理 mqttTool.message = function(){ return new Promise((resolve, reject) => { if(mqttTool.client == null){ resolve('未连接') console.log('App_text' + ":unconnect 未连接") return; } if(mqttTool.client != null && ! mqttTool.client.connected){ mqttTool.client.reconnect() } mqttTool.client.on('message', function(topic, message, buffer) { console.info(topic) console.info(message) setTimeout(() => { resolve({topic, message, buffer }) }, 300) }) }) }