diff --git a/mqttc.py b/mqttc.py index cacefd2..df392cb 100644 --- a/mqttc.py +++ b/mqttc.py @@ -102,7 +102,7 @@ def start_mqtt(): client.on_message = on_message client.on_disconnect = on_disconnect client.connect(host=conf.MQTT_HOST, port=conf.MQTT_PORT) - client.loop_start() + client.loop_forever() if __name__ == '__main__':