diff --git a/prod_rmq_agents/notify_user.py b/prod_rmq_agents/notify_user.py index 4b64586a11d151dd6e9351ffca3e54fefafe928c..73570df55c38b3d4c018473da3a5aa52a96b485f 100644 --- a/prod_rmq_agents/notify_user.py +++ b/prod_rmq_agents/notify_user.py @@ -20,6 +20,7 @@ table = db["users"] # Instantiate rabbitmq object rc_rmq = RCRMQ({"exchange": "RegUsr", "exchange_type": "topic"}) + # Email instruction to user def notify_user(ch, method, properties, body): msg = json.loads(body) diff --git a/prod_rmq_agents/user_reg_logger.py b/prod_rmq_agents/user_reg_logger.py index 0ec09c526059ad4c731075905820dd46ce4f6ed0..a9c878e4216ab4718b9fb579d6e194e9e8ba8e87 100755 --- a/prod_rmq_agents/user_reg_logger.py +++ b/prod_rmq_agents/user_reg_logger.py @@ -21,6 +21,7 @@ logger = rc_util.get_logger() db = dataset.connect("sqlite:///.agent_db/reg_logger.db") account_req_table = db["registry"] + # Define registration logger callback def log_registration(ch, method, properties, body):