diff --git a/src/main.ts b/src/main.ts index 02c35ea..0de272b 100644 --- a/src/main.ts +++ b/src/main.ts @@ -22,7 +22,7 @@ let heartbeatTimer = setInterval(() => { -let mqttClient = Mqtt.connect(this.options.broker) +let mqttClient = Mqtt.connect(config.dict.brokerUrl) mqttClient.on('offline', () => { log.warn("MQTT client is offline") }) mqttClient.on('reconnect', () => { log.warn("MQTT client is reconnecting") }) mqttClient.on('close', () => { log.warn("MQTT connection closed") }) @@ -40,7 +40,7 @@ mqttClient.on('message', (topic : string, messageBuf : Buffer) => { let message = messageBuf.toString('UTF-8') log.info(`Message received ${this.msgCnt}, topic ${topic}, payload ${message}`) } - + LED2.writeSync(1) setTimeout(() => { LED2.writeSync(0)