diff --git a/utils/mqtt_sender/mqtt_sender.py b/utils/mqtt_sender/mqtt_sender.py index f610b3db..9484f753 100644 --- a/utils/mqtt_sender/mqtt_sender.py +++ b/utils/mqtt_sender/mqtt_sender.py @@ -29,7 +29,9 @@ def redis_listen(client, logger): if data: info = data[1].split('|') logger.info("Channel: " + info[0] + " message: " + info[1]) - client.publish(info[0], info[1]) + #client.publish(info[0], info[1]) + # set QoS level to 1 for published messages + client.publish(info[0], info[1], 1)