diff --git a/prod_rmq_agents/user_reg_event_logger.py b/prod_rmq_agents/user_reg_event_logger.py index 177b2c97ff543e0f05936991a1512fa6a975cfdf..0b8499c6a0fd288485868addeaf429b97ceda8c0 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