Added transport option to Client construnctor

empicano · Nov 5, 2020 · 9a4591b · 9a4591b
1 parent 0e7f77a
commit 9a4591b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/asyncio_mqtt/client.py b/asyncio_mqtt/client.py
@@ -18,7 +18,7 @@
 class Client:
     def __init__(self, hostname, port=1883, *, username=None, password=None,
                  logger=None, client_id=None, tls_context=None, protocol=None,
-                 will=None, clean_session=None):
+                 will=None, clean_session=None, transport="tcp"):
         self._hostname = hostname
         self._port = port
         self._loop = asyncio.get_event_loop()
@@ -31,7 +31,7 @@ def __init__(self, hostname, port=1883, *, username=None, password=None,
         if protocol is None:
             protocol = mqtt.MQTTv311
 
-        self._client = mqtt.Client(client_id=client_id, protocol=protocol, clean_session=clean_session)
+        self._client = mqtt.Client(client_id=client_id, protocol=protocol, clean_session=clean_session, transport=transport)
         self._client.on_connect = self._on_connect
         self._client.on_disconnect = self._on_disconnect
         self._client.on_subscribe = self._on_subscribe