t

examples/mqtt.py

@@ -16,41 +16,51 @@ from paho.mqtt import client as mqtt_client
 
 logging.basicConfig(level=logging.DEBUG)
 
-broker = 'homeassistant'
+Connected = False
+
+
+
+def connect_mqtt() -> mqtt_client:
+    def on_connect(client, userdata, flags, rc):
+        if rc == 0:
+            print("Connected to MQTT Broker!")
+
+            global Connected                #Use global variable
+            Connected = True                #Signal connection 
+        else:
+            print("Failed to connect, return code %d\n", rc)
+
+def on_message(client, userdata, msg):
+     print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")
+
+Connected = False   #global variable for the state of the connection
+
+broker = "homeassistant"
 port = 8883
 topic = "openWB/evu/W"
 username = "mqtt-user"
 password = "phio6yiR9ohs1veeghu4WaeGhaiRi8he4EiWasheev4faeku8tohdiuthah7zahP"
 client_id = "solarmonitor"
 
-def connect_mqtt() -> mqtt_client:
+client = mqtt_client.Client(client_id)
-    def on_connect(client, userdata, flags, rc):
+client.username_pw_set(username, password)
-        if rc == 0:
+client.on_connect = on_connect
-            print("Connected to MQTT Broker!")
+client.on_message = on_message
-        else:
-            print("Failed to connect, return code %d\n", rc)
 
-    client = mqtt_client.Client(client_id)
+client.connect(broker, port)
-    client.username_pw_set(username, password)
-    client.on_connect = on_connect
-    client.connect(broker, port)
-    return client
 
-def subscribe(client: mqtt_client):
+client.loop_start()        #start the loop
-    def on_message(client, userdata, msg):
-        print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")
   
-    client.subscribe(topic)
+while Connected != True:    #Wait for connection
-    client.on_message = on_message
+    time.sleep(0.1)
 
+client.subscribe(topic)
 
-def run():
+try:
-    print("test")
+    while True:
-    client = connect_mqtt()
+        time.sleep(1)
-    print("conected")
-    subscribe(client)
-    client.loop_forever()
   
-
+except KeyboardInterrupt:
-if __name__ == '__main__':
+    print "exiting"
-    run()
+    client.disconnect()
+    client.loop_stop()