diff --git a/utils/mqtt_sender/mqtt_sender.py b/utils/mqtt_sender/mqtt_sender.py index 0762a299..07e81174 100644 --- a/utils/mqtt_sender/mqtt_sender.py +++ b/utils/mqtt_sender/mqtt_sender.py @@ -27,7 +27,7 @@ def on_publish(client, userdata, mid): -def getRedis(i): +def getRedis(i, client): r = redis.StrictRedis(host='localhost', port=6379, db=0) while 1: time.sleep(0) @@ -56,7 +56,7 @@ def main(): tls_version=ssl.PROTOCOL_TLSv1) client.connect("resqaws.jankstudio.com", 8883, 60) - t = Thread(target=getRedis, args=(1,)) + t = Thread(target=getRedis, args=(1, client)) t.start() @@ -65,6 +65,7 @@ def main(): -pid = "/tmp/mqtt_sender.pid" -daemon = Daemonize(app="mqtt_sender", pid=pid, action=main) -daemon.start() +#pid = "/tmp/mqtt_sender.pid" +#daemon = Daemonize(app="mqtt_sender", pid=pid, action=main) +#daemon.start() +main()