diff --git a/agent_template.py b/agent_template.py index b653f81f1f5af989639d1be9cda93da2f8f11894..07400ae1f95b82c2ac1e1b4902b68a1c14e57dd6 100644 --- a/agent_template.py +++ b/agent_template.py @@ -7,6 +7,7 @@ task = "task_name" # Instantiate rabbitmq object rc_rmq = RCRMQ({"exchange": "RegUsr", "exchange_type": "topic"}) + # Define your callback function def on_message(ch, method, properties, body): diff --git a/prod_rmq_agents/get-next-uid-gid.py b/prod_rmq_agents/get-next-uid-gid.py index 714ab8c3b784607b13981e0ceebe00f5c80c2b2b..2695ce61f93a938f770e3401900a85f5609e2920 100644 --- a/prod_rmq_agents/get-next-uid-gid.py +++ b/prod_rmq_agents/get-next-uid-gid.py @@ -18,9 +18,8 @@ args = rc_util.get_args() # Logger logger = rc_util.get_logger() -# Account creation - +# Account creation def create_account(msg): logger.info(f"Account creation request received: {msg}") diff --git a/prod_rmq_agents/user_reg_event_logger.py b/prod_rmq_agents/user_reg_event_logger.py index 3223255c19825462d22b05df3fc01dc92d6815c9..177b2c97ff543e0f05936991a1512fa6a975cfdf 100644 --- a/prod_rmq_agents/user_reg_event_logger.py +++ b/prod_rmq_agents/user_reg_event_logger.py @@ -7,6 +7,7 @@ task = "user_reg_event_log" # Instantiate rabbitmq object rc_rmq = RCRMQ({"exchange": "RegUsr", "exchange_type": "topic"}) + # Define your callback function def log_user_reg_events(ch, method, properties, body):