From 9a4591bd84bbf8c6257161703aa277c89a3a2726 Mon Sep 17 00:00:00 2001 From: Mykola Zhyhallo Date: Thu, 5 Nov 2020 12:38:53 +0100 Subject: [PATCH] Added transport option to Client construnctor --- asyncio_mqtt/client.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/asyncio_mqtt/client.py b/asyncio_mqtt/client.py index ea91187..640e297 100644 --- 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