Commit e9fcbe98 authored by Krish Moodbidri's avatar Krish Moodbidri
Browse files

changed rc_util function calls to match rabbitmq agent modification

parent 8418b669
Pipeline #4628 failed with stage
......@@ -51,11 +51,12 @@ def celery_create_account(json, session):
email= json['email']
fullname= json['fullname']
reason= json['reason']
queuename= rc_util.encode_name(username)
print(time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue')
send_msg('creating account', room)
rc_util.add_account(username, email, fullname, reason)
rc_util.add_account(username, queuename, email, fullname, reason)
print('sent account info')
print('Waiting for completion...')
rc_util.consume(username, routing_key=f'complete.{username}', callback=gen_f(room))
rc_util.consume(queuename, routing_key=f'complete.{queuename}', callback=gen_f(room))
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment