@@ -91,7 +91,7 @@ def device_twin_desired_updated(self, desired_property_name: str, desired_proper
91
91
:param int desired_version: The version of the desired property that was updated
92
92
"""
93
93
94
- def device_twin_reported_updated (self , reported_property_name : str , reported_property_value , reported_version : int , ) -> None :
94
+ def device_twin_reported_updated (self , reported_property_name : str , reported_property_value , reported_version : int ) -> None :
95
95
"""Called when the device twin reported values are updated
96
96
:param str reported_property_name: The name of the reported property that was updated
97
97
:param reported_property_value: The value of the reported property that was updated
@@ -114,12 +114,11 @@ def _gen_sas_token(self) -> str:
114
114
token = "SharedAccessSignature sr={}&sig={}&se={}" .format (uri , signature , token_expiry )
115
115
return token
116
116
117
- # Workaround for https://github.com/adafruit/Adafruit_CircuitPython_MiniMQTT/issues/25
118
- def _try_create_mqtt_client (self , hostname : str ) -> None :
117
+ def _create_mqtt_client (self ) -> None :
119
118
minimqtt .set_socket (self ._socket , self ._iface )
120
119
121
120
self ._mqtts = MQTT (
122
- broker = hostname ,
121
+ broker = self . _hostname ,
123
122
username = self ._username ,
124
123
password = self ._passwd ,
125
124
port = 8883 ,
@@ -142,9 +141,6 @@ def _try_create_mqtt_client(self, hostname: str) -> None:
142
141
self ._mqtts .last_will ()
143
142
self ._mqtts .connect ()
144
143
145
- def _create_mqtt_client (self ) -> None :
146
- self ._try_create_mqtt_client (self ._hostname )
147
-
148
144
# pylint: disable=C0103, W0613
149
145
def _on_connect (self , client , userdata , _ , rc ) -> None :
150
146
self ._logger .info ("- iot_mqtt :: _on_connect :: rc = " + str (rc ) + ", userdata = " + str (userdata ))
0 commit comments