diff --git a/backend/src/DataSource/MqttSource.ts b/backend/src/DataSource/MqttSource.ts index 152350d..1e6e821 100644 --- a/backend/src/DataSource/MqttSource.ts +++ b/backend/src/DataSource/MqttSource.ts @@ -65,6 +65,11 @@ export class MqttSource implements DataSource { throw new Error('mqtt subscription failed') } }) + client.subscribe('$SYS/#', (err: Error) => { + if (err) { + throw new Error('mqtt subscription failed') + } + }) }) client.on('message', (topic, message, packet) => {