notification/mqtt: ensure network communication and check error

rwstauner · May 12, 2013 · 98ddb1c · 98ddb1c
1 parent 2a091a3
commit 98ddb1c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/library/notification/mqtt b/library/notification/mqtt
@@ -119,6 +119,9 @@ def publish(module, topic, payload, server='localhost', port='1883', qos='0',
         module.fail_json(msg="unable to connect to MQTT broker")
 
     mqttc.publish(topic, payload, int(qos), retain)
+    rc = mqttc.loop()
+    if rc != 0:
+        module.fail_json(msg="unable to send to MQTT broker")
 
     mqttc.disconnect()