|
|
@ -96,8 +96,7 @@ exports.mqttAsync = function (hostname, topic, okMessage) {
|
|
|
|
let client = mqtt.connect(hostname);
|
|
|
|
let client = mqtt.connect(hostname);
|
|
|
|
client.on("connect", () => {
|
|
|
|
client.on("connect", () => {
|
|
|
|
client.subscribe(topic);
|
|
|
|
client.subscribe(topic);
|
|
|
|
}
|
|
|
|
});
|
|
|
|
);
|
|
|
|
|
|
|
|
client.on("message", (messageTopic, message) => {
|
|
|
|
client.on("message", (messageTopic, message) => {
|
|
|
|
console.log(messageTopic);
|
|
|
|
console.log(messageTopic);
|
|
|
|
if (messageTopic == topic && message.toString() !== okMessage) {
|
|
|
|
if (messageTopic == topic && message.toString() !== okMessage) {
|
|
|
|