From ea0ead21c6d08a5cb9e104082c17a0bdb8257a6a Mon Sep 17 00:00:00 2001
From: "Bo-Chun Louis Chen(VM)" <louistw@uab.edu>
Date: Mon, 16 Mar 2020 21:23:44 +0000
Subject: [PATCH] Add debug message in RCRMQ class
---
rc_rmq.py | 22 +++++++++++++++++++++-
1 file changed, 21 insertions(+), 1 deletion(-)
diff --git a/rc_rmq.py b/rc_rmq.py
index f3102d4..a91a80d 100644
--- a/rc_rmq.py
+++ b/rc_rmq.py
@@ -15,8 +15,9 @@ class RCRMQ(object):
QUEUE = None
DURABLE = True
ROUTING_KEY = None
+ DEBUG = False
- def __init__(self, config=None):
+ def __init__(self, config=None, debug=False):
if config:
if 'exchange' in config:
self.EXCHANGE = config['exchange']
@@ -30,6 +31,19 @@ class RCRMQ(object):
self.PASSWORD = rcfg.Password
self.VHOST = rcfg.VHost
self.PORT = rcfg.Port
+ self.DEBUG = debug
+
+ if self.DEBUG:
+ print("""
+ Created RabbitMQ instance with:
+ Exchange name: {},
+ Exchange type: {},
+ Host: {},
+ User: {},
+ VHost: {},
+ Port: {}
+ """.format(self.EXCHANGE, self.EXCHANGE_TYPE, self.HOST, self.USER, self.VHOST, self.PORT))
+
self._parameters = pika.ConnectionParameters(
self.HOST,
self.PORT,
@@ -37,6 +51,9 @@ class RCRMQ(object):
pika.PlainCredentials(self.USER, self.PASSWORD))
def connect(self):
+ if self.DEBUG:
+ print("Connecting...\n" + "Exchange: " + self.EXCHANGE + " Exchange type: " + self.EXCHANGE_TYPE)
+
self._connection = pika.BlockingConnection(self._parameters)
self._channel = self._connection.channel()
self._channel.exchange_declare(
@@ -76,6 +93,9 @@ class RCRMQ(object):
if 'durable' in obj:
self.DURABLE = obj['durable']
+ if self.DEBUG:
+ print("Queue: " + self.QUEUE + "\nRouting_key: " + self.ROUTING_KEY)
+
self.connect()
self._consumer_tag = self._channel.basic_consume(self.QUEUE,obj['cb'])
--
GitLab