Skip to content
Snippets Groups Projects
Commit 8a37e8e4 authored by Eesaan Atluri's avatar Eesaan Atluri
Browse files

Send corr_id and callback queue info to the agents with properties

parent c39f329c
No related branches found
No related tags found
2 merge requests!147Merge previous default branch feat-cod-rmq into main,!119Feat account management
...@@ -44,10 +44,14 @@ else: ...@@ -44,10 +44,14 @@ else:
print("Invalid state provided. Check the help menu.") print("Invalid state provided. Check the help menu.")
if args.all is not None: if args.all is not None:
if args.service == 'all':
# send a broadcast message to all agents # send a broadcast message to all agents
rc_rmq.publish_msg( rc_rmq.publish_msg(
{ {
"routing_key": f"{action}.{username}", "routing_key": f"{action}.{username}",
"props": pika.BasicProperties(
correlation_id=corr_id, reply_to=callback_queue
),
"msg": {"username": username, "action": action, "service": service}, "msg": {"username": username, "action": action, "service": service},
} }
) )
......
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