diff --git a/src/officesense_pi/src/core/mqtt.ts b/src/officesense_pi/src/core/mqtt.ts index 11fe6a3..747a1f4 100644 --- a/src/officesense_pi/src/core/mqtt.ts +++ b/src/officesense_pi/src/core/mqtt.ts @@ -13,13 +13,13 @@ function initMqtt(): Promise { ); client.once("connect", () => { - console.log("MQTT connected."); + console.log("[MQTT] MQTT connected."); client.subscribe(config.mqtt.topic, (err) => { if (err) { reject(err); } else { - console.log("MQTT subscribed."); + console.log("[MQTT] MQTT subscribed."); resolve(client); } }); @@ -43,6 +43,6 @@ export async function start() { console.log(err.message); }) } catch (err: any) { - console.log("MQTT connection failed:", err.message); + console.log("[MQTT] MQTT connection failed:", err.message); } }