Transport: stop service if mqtt connection cannot be established

wirepas · Jul 8, 2019 · 1c23ac1 · 1c23ac1
1 parent 12fbed5
commit 1c23ac1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/python_transport/wirepas_gateway/protocol/mqtt_wrapper.py b/python_transport/wirepas_gateway/protocol/mqtt_wrapper.py
@@ -10,6 +10,7 @@
 from time import sleep
 
 from paho.mqtt import client as mqtt
+from paho.mqtt.client import connack_string
 
 
 class MQTTWrapper(Thread):
@@ -69,7 +70,8 @@ def __init__(self, logger, username, password, host, port, secure_auth=True, ca_
 
     def _on_connect(self, client, userdata, flags, rc):
         if rc != 0:
-            self.logger.error("MQTT cannot connect {}".format(rc))
+            self.logger.error("MQTT cannot connect: {}".format(connack_string(rc)))
+            self.running = False
             return
 
         if self.on_connect_cb is not None: