From 8a37e8e45459cf085625abf89a4247441be1e683 Mon Sep 17 00:00:00 2001
From: atlurie <atlurie@uab.edu>
Date: Thu, 7 Apr 2022 23:13:13 -0500
Subject: [PATCH] Send corr_id and callback queue info to the agents with
properties
---
account_manager.py | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/account_manager.py b/account_manager.py
index 5cecb28..b2b037e 100755
--- a/account_manager.py
+++ b/account_manager.py
@@ -44,10 +44,14 @@ else:
print("Invalid state provided. Check the help menu.")
if args.all is not None:
+if args.service == 'all':
# send a broadcast message to all agents
rc_rmq.publish_msg(
{
"routing_key": f"{action}.{username}",
+ "props": pika.BasicProperties(
+ correlation_id=corr_id, reply_to=callback_queue
+ ),
"msg": {"username": username, "action": action, "service": service},
}
)
--
GitLab