Skip to content
Snippets Groups Projects

WIP: Feat use queuename attribute for routing key

Created by: rtripath89

Merge request reports

Loading
Loading

Activity

Filter activity
  • Approvals
  • Assignees & reviewers
  • Comments (from bots)
  • Comments (from users)
  • Commits & branches
  • Edits
  • Labels
  • Lock status
  • Mentions
  • Merge request status
  • Tracking
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):
  • Created by: rtripath89

    Superseded by #92 and #93

  • Please register or sign in to reply
    Loading