use port in mqtt

mralext20 · Apr 20, 2024 · 4488190 · 4488190
1 parent 6f20192
commit 4488190
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/alexBot/cogs/mqttDispatcher.py b/alexBot/cogs/mqttDispatcher.py
@@ -23,7 +23,7 @@ async def mqttLoop(self):
             try:
                 url = urlparse(self.bot.config.mqtt_url)
                 async with aiomqtt.Client(
-                    hostname=url.hostname, username=url.username, password=url.password
+                    hostname=url.hostname, username=url.username, password=url.password, port=url.port
                 ) as client:
                     self.active_client = client
                     async with client.messages() as messages: