diff --git a/front/plugins/_publisher_mqtt/mqtt.py b/front/plugins/_publisher_mqtt/mqtt.py
index 21a8faaf..fade6e18 100755
--- a/front/plugins/_publisher_mqtt/mqtt.py
+++ b/front/plugins/_publisher_mqtt/mqtt.py
@@ -65,6 +65,7 @@ def main():
     db.open()
 
     mqtt_start(db)
+    mqtt_client.disconnect()
 
     plugin_objects.write_result_file()
 
@@ -431,7 +432,6 @@ def mqtt_start(db):
     global mqtt_client, mqtt_connected_to_broker
 
     if not mqtt_connected_to_broker:
-        mqtt_connected_to_broker = True
         mqtt_client = mqtt_create_client()