From 1fe0507e2349a318f4e2a3bc6a740e84a7bed546 Mon Sep 17 00:00:00 2001 From: Eesaan Atluri <atlurie@uab.edu> Date: Fri, 24 Apr 2020 15:35:39 +0000 Subject: [PATCH] Use logging from rc_util --- user_reg_logger.py | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/user_reg_logger.py b/user_reg_logger.py index dec5c18..0f890a9 100755 --- a/user_reg_logger.py +++ b/user_reg_logger.py @@ -2,7 +2,7 @@ import json import sys import dataset -import logging +import rc_util from rc_rmq import RCRMQ from datetime import datetime @@ -10,7 +10,13 @@ from datetime import datetime task = 'reg_logger' # Instantiate rabbitmq object -reg_logger = RCRMQ({'exchange': 'RegUsr', 'exchange_type': 'topic'}) +rc_rmq = RCRMQ({'exchange': 'RegUsr', 'exchange_type': 'topic'}) + +# Parse arguments +args = rc_util.get_args() + +# Logger +logger = rc_util.get_logger()# Define your callback function # Parse arguments args = rc_util.get_args() @@ -35,7 +41,7 @@ def log_registration(ch, method, properties, body): logger.info("Start listening to queue: {}".format(task)) # Start consuming messages from queue with callback function -reg_logger.start_consume({ +rc_rmq.start_consume({ 'queue': task, 'routing_key': "create.*", 'cb': log_registration -- GitLab