Skip to content
Snippets Groups Projects
Commit 49dfe554 authored by Bo-Chun Chen's avatar Bo-Chun Chen
Browse files

Fix variable name

Change to only one exchange, so there's only one instance, rc_rmq
parent 0a126066
No related branches found
No related tags found
1 merge request!18Redesign RabbitMQ
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment