From 6bd5bfbf7cd66a1c0efe334ee12a03731d6f681e Mon Sep 17 00:00:00 2001
From: Bo-Chun Louis Chen <louistw@uab.edu>
Date: Fri, 29 Mar 2024 01:17:50 -0500
Subject: [PATCH] fix: remove assumption on routing_key
---
prod_rmq_agents/user_reg_event_logger.py | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/prod_rmq_agents/user_reg_event_logger.py b/prod_rmq_agents/user_reg_event_logger.py
index 177b2c9..0b8499c 100644
--- a/prod_rmq_agents/user_reg_event_logger.py
+++ b/prod_rmq_agents/user_reg_event_logger.py
@@ -10,15 +10,12 @@ rc_rmq = RCRMQ({"exchange": "RegUsr", "exchange_type": "topic"})
# Define your callback function
def log_user_reg_events(ch, method, properties, body):
-
# Retrieve message
msg = json.loads(body)
# Retrieve routing key
routing_key = method.routing_key
- action = routing_key.split(".")[0]
- user = routing_key.split(".")[1]
- print(f"Got a {action} message for {user} with routing key: {routing_key}")
+ print(f"Got a message with routing key: {routing_key}")
print(msg)
# Acknowledge message
--
GitLab