diff --git a/rc_util.py b/rc_util.py index 8b90fce92b86c7e8465d3664c0c1271bdca404db..78a18372fa3fffd79938cc5c99f3d8cbdfee58f7 100644 --- a/rc_util.py +++ b/rc_util.py @@ -27,14 +27,14 @@ def worker(ch, method, properties, body): print("{} is not done yet.".format(key)) done = False if done: - confirm_rmq.stop_consume() - confirm_rmq.delete_queue() + rc_rmq.stop_consume() + rc_rmq.delete_queue() def consume(username, callback, debug=False): if debug: sleep(5) else: - confirm_rmq.start_consume({ + rc_rmq.start_consume({ 'queue': username, 'routing_key': 'confirm.' + username, 'cb': callback