From 49dfe554076dcd9587fac15dccdcf969cf402899 Mon Sep 17 00:00:00 2001 From: "Bo-Chun Louis Chen(VM)" <louistw@uab.edu> Date: Mon, 23 Mar 2020 19:24:51 +0000 Subject: [PATCH] Fix variable name Change to only one exchange, so there's only one instance, rc_rmq --- rc_util.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/rc_util.py b/rc_util.py index 8b90fce..78a1837 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 -- GitLab