migrate asyncio-mqtt to aiomqtt (#235)

markusressel · May 29, 2024 · 6efa771 · 6efa771
1 parent 9e9ddd4
commit 6efa771
Show file tree

Hide file tree

Showing 3 changed files with 449 additions and 408 deletions.
diff --git a/barcode_server/notifier/mqtt.py b/barcode_server/notifier/mqtt.py
@@ -1,6 +1,6 @@
 import logging
 
-from asyncio_mqtt import Client
+from aiomqtt import Client
 from prometheus_async.aio import time
 
 from barcode_server.barcode import BarcodeEvent
@@ -33,6 +33,6 @@ async def _send_event(self, event: BarcodeEvent):
         json = barcode_event_to_json(self.config.INSTANCE_ID.value, event)
         async with Client(hostname=self.host, port=self.port,
                           username=self.user, password=self.password,
-                          client_id=self.client_id) as client:
+                          identifier=self.client_id) as client:
             await client.publish(self.topic, json, self.qos, self.retain)
             LOGGER.debug(f"Notified {self.host}:{self.port}: {event.barcode}")