Use MQTTv5 and shared subscriptions (#76)

* Connect with MQTTv5 * Use shared subscription
dnstapir · Feb 12, 2025 · b564644 · b564644
1 parent 1ea1c25
commit b564644
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -12,6 +12,6 @@ The default configuration file is `evrec.toml`. Example configuration below:
 
     [mqtt]
     broker = "mqtt://localhost"
-    topic_read = "events/up/#"
+    topic_read = "$share/evrec/events/up/#"
     topic_write = "verified"
     reconnect_interval = 5
diff --git a/evrec/server.py b/evrec/server.py
@@ -48,6 +48,7 @@ async def run(self):
                     port=self.settings.mqtt.broker.port,
                     username=self.settings.mqtt.broker.username,
                     password=self.settings.mqtt.broker.password,
+                    protocol=aiomqtt.ProtocolVersion.V5,
                 ) as client:
                     self.logger.info("MQTT connected to %s", self.settings.mqtt.broker)
                     await client.subscribe(self.settings.mqtt.topic_read)