This commit is contained in:
2024-08-17 11:17:55 +02:00

View File

@@ -84,9 +84,9 @@ class Lineplug extends DeviceBase {
// monitor queue // monitor queue
this.mqtt.on('message', (topic, message) => { this.mqtt.on('message', (topic, message) => {
// message is Buffer // message is Buffer
if (topic == this.topic_set) { // verify that the topic is correct
let payload = message.toString() let payload = message.toString()
this.logger.debug(`input ${topic}: ${payload}`) this.logger.debug(`input ${topic}: ${payload}`)
try { try {
const jsonpayload = JSON.parse(payload) const jsonpayload = JSON.parse(payload)
if (jsonpayload.value != undefined) { if (jsonpayload.value != undefined) {
@@ -100,6 +100,7 @@ class Lineplug extends DeviceBase {
this.logger.trace(payload) this.logger.trace(payload)
this.logger.trace(error) this.logger.trace(error)
} }
}
}) })
} }