Skip to content
Snippets Groups Projects

Feat cod rmq

Closed Krish Moodbidri requested to merge github/fork/krishmoodbidri/feat-cod-rmq into feat-cod-rmq
2 files
+ 20
5
Compare changes
  • Side-by-side
  • Inline
Files
2
+ 15
0
@@ -87,6 +87,21 @@ def certify_account(
)
rc_rmq.disconnect()
def certify_account(username, queuename, state="ok", service="all"):
rc_rmq.publish_msg(
{
"routing_key": "acctmgr.request." + queuename,
"msg": {
"username": username,
"service": service,
"state": state,
"queuename": queuename,
},
}
)
rc_rmq.disconnect()
def worker(ch, method, properties, body):
msg = json.loads(body)
Loading