diff --git a/user_reg_event_logger.py b/user_reg_event_logger.py new file mode 100644 index 0000000000000000000000000000000000000000..02c12483ce3540e8f36c2d902f998c6e1ba50f9b --- /dev/null +++ b/user_reg_event_logger.py @@ -0,0 +1,33 @@ +#!/usr/bin/env python +import sys +import json +from rc_rmq import RCRMQ + +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): + + # 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(msg) + + # Acknowledge message + ch.basic_ack(delivery_tag=method.delivery_tag) + + +print("Start listening to queue: {}".format(task)) +rc_rmq.start_consume({ + 'queue': task, # Define your Queue name + 'routing_key': "#", # Define your routing key + 'cb': log_user_reg_events # Pass in callback function you just define +})