diff --git a/rc_util.py b/rc_util.py index df275037c1895b0374c2a9e6faabdea3a7eeaf3a..e0c2643562c7371f0f320f9b12cadf0599f1584e 100644 --- a/rc_util.py +++ b/rc_util.py @@ -30,13 +30,13 @@ def worker(ch, method, properties, body): confirm_rmq.stop_consume() confirm_rmq.delete_queue() -def consume(username, worker, debug=False): +def consume(username, callback, debug=False): if debug: sleep(5) else: confirm_rmq.start_consume({ 'queue': username, - 'cb': worker + 'cb': callback }) return { 'success' : True }