1 files changed, 3 insertions, 1 deletions
diff --git a/src/lib/mqtt.ts b/src/lib/mqtt.ts
index f7dd82c..71ba553 100644
--- a/src/lib/mqtt.ts
+++ b/src/lib/mqtt.ts
@@ -47,7 +47,9 @@ export async function addListener(topic, callback) {
 
     // todo: error handling
 
-    client.on("message", (_, message) => {
+    client.on("message", (receivedTopic, message) => {
+        if (receivedTopic !== mqttTopic) return
+
         callback(message)
     })
 }