diff --git a/rc_rmq.py b/rc_rmq.py index f3102d496b09e7ad7a325eaf53c1672d96856288..a91a80dc0dc150700a654165a6e00669c7b4297d 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'])