From a6a640d40f60994593d3be8c063ca8c1c89e8e50 Mon Sep 17 00:00:00 2001 From: puuu Date: Wed, 27 Jul 2016 00:03:01 +0900 Subject: [PATCH] umqtt.robust: publish() adapt to umqtt.simple umqtt.simple uses publish(self, topic, msg, retain=False, qos=0), so make umqtt.robust use the same. Otherwise, retain and qos will not work. --- umqtt.robust/umqtt/robust.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/umqtt.robust/umqtt/robust.py b/umqtt.robust/umqtt/robust.py index 26bb65946..7ee40e020 100644 --- a/umqtt.robust/umqtt/robust.py +++ b/umqtt.robust/umqtt/robust.py @@ -26,10 +26,10 @@ def reconnect(self): i += 1 self.delay(i) - def publish(self, topic, msg, qos=0, retain=False): + def publish(self, topic, msg, retain=False, qos=0): while 1: try: - return super().publish(topic, msg, qos, retain) + return super().publish(topic, msg, retain, qos) except OSError as e: self.log(False, e) self.reconnect()