Skip to content

Commit a2032c0

Browse files
committed
Update adafruit_minimqtt.py
1 parent df63c8f commit a2032c0

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

adafruit_minimqtt/adafruit_minimqtt.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -459,7 +459,7 @@ def connect(self, clean_session=True, host=None, port=None, keep_alive=None):
459459
var_header[7] |= self.keep_alive >> 8
460460
var_header[8] |= self.keep_alive & 0x00FF
461461
if self._lw_topic:
462-
remaining_length += 2 + len(self._lw_topic.encode("utf-8")) + 2 + len(self._lw_msg.encode("utf-8"))
462+
remaining_length += 2 + len(self._lw_topic.encode("utf-8")) + 2 + len(self._lw_msg)
463463
var_header[6] |= 0x4 | (self._lw_qos & 0x1) << 3 | (self._lw_qos & 0x2) << 3
464464
var_header[6] |= self._lw_retain << 5
465465

@@ -914,10 +914,11 @@ def _send_str(self, string):
914914
:param str string: String to write to the socket.
915915
916916
"""
917-
self._sock.send(struct.pack("!H", len(string.encode("utf-8"))))
918917
if isinstance(string, str):
918+
self._sock.send(struct.pack("!H", len(string.encode("utf-8"))))
919919
self._sock.send(str.encode(string, "utf-8"))
920920
else:
921+
self._sock.send(struct.pack("!H", len(string)))
921922
self._sock.send(string)
922923

923924
@staticmethod

0 commit comments

Comments
 (0)