Start the mqtt.Client loop (threaded)

openknot · Jul 29, 2015 · 2bd096f · 2bd096f
1 parent ef64fb9
commit 2bd096f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/broker/mqtt.py b/broker/mqtt.py
@@ -28,6 +28,7 @@ def init(self, url):
         self.client.on_message = self._on_message
 
         self.client.connect(host, port)
+        self.client.loop_start()
 
     def _on_connect(self, client, userdata, flags, rc):
         print("Connected with result code {0}".format(rc))