From 20cd8e46517fef0bb67b5c909509294fe0b927e0 Mon Sep 17 00:00:00 2001 From: puuu Date: Wed, 27 Jul 2016 00:03:01 +0900 Subject: [PATCH] umqtt.robust: publish(): Adapt signature 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 26bb6594..7ee40e02 100644 --- a/umqtt.robust/umqtt/robust.py +++ b/umqtt.robust/umqtt/robust.py @@ -26,10 +26,10 @@ class MQTTClient(simple.MQTTClient): 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()