diff --git a/rc_util.py b/rc_util.py index 05ff5c2992374dcc8ab52818d3ec37f869bb07e1..df275037c1895b0374c2a9e6faabdea3a7eeaf3a 100644 --- a/rc_util.py +++ b/rc_util.py @@ -17,11 +17,9 @@ def add_account(username, full='', reason=''): def worker(ch, method, properties, body): msg = json.loads(body) - task = msg['username'] + task = msg['task'] print("get msg: {}".format(task)) - - tasks[task] = True - ch.basic_ack(delivery_tag=method.delivery_tag) + tasks[task] = msg['success'] # Check if all tasks are done done = True