wn/dispatcher_ng
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

reduced logging

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2018-03-27 21:31:03 +02:00
parent 166f958cac
commit 656db81602
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/AItem.ts
View File

@ -47,7 +47,7 @@ export abstract class AItem {
start() : void { start() : void {
mqttHandler.register(this.subscribeTopics, (topic: string, payload: string) : void => { mqttHandler.register(this.subscribeTopics, (topic: string, payload: string) : void => {
logger.info(`item ${this.itemId}: ${topic}, ${payload}`) // logger.info(`item ${this.itemId}: ${topic}, ${payload}`)
this.processMessage(topic, payload) this.processMessage(topic, payload)
}) })
} }

2
src/MqttDispatcher.ts
View File

@ -63,7 +63,7 @@ class MqttHandler {
this.mqttClient.on('message', (topic: string, payload: Buffer, packet : Mqtt.IPublishPacket): void => { this.mqttClient.on('message', (topic: string, payload: Buffer, packet : Mqtt.IPublishPacket): void => {
if (! packet.retain) { if (! packet.retain) {
let payloadStr : string = payload.toString('UTF-8') let payloadStr : string = payload.toString('UTF-8')
logger.info(`Message received on topic ${topic}: ${payload}`) // logger.info(`Message received on topic ${topic}: ${payload}`)
this.processMessage(topic, payloadStr) this.processMessage(topic, payloadStr)
} }
}) })