Merge pull request #32 from eesaanatluri/feat-user-reg-event-logger

Feat user reg event logger

user_reg_event_logger.py

+#!/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
+})