WIP: Feat use queuename attribute for routing key
Created by: rtripath89
Merge request reports
Activity
Filter activity
39 print(f"Account for {username} has been created.") 28 40 else: 29 41 print(f"There's some issue while creating account for {username}") 30 errmsg = msg.get('errmsg', []) 42 errmsg = msg.get("errmsg", []) 31 43 for err in errmsg: 32 44 print(err) 33 45 34 46 rc_rmq.stop_consume() 35 47 rc_rmq.delete_queue() 36 48 37 def consume(username, routing_key='', callback=worker, debug=False): 38 if routing_key == '': 39 routing_key = 'complete.' + username 49 50 def consume(username, routing_key="", callback=worker, debug=False):
Please register or sign in to reply