diff --git a/rc_rmq.py b/rc_rmq.py index a91a80dc0dc150700a654165a6e00669c7b4297d..35922b230fcfa26b5148c9dcf5662a8345abf4ca 100644 --- a/rc_rmq.py +++ b/rc_rmq.py @@ -44,6 +44,10 @@ class RCRMQ(object): Port: {} """.format(self.EXCHANGE, self.EXCHANGE_TYPE, self.HOST, self.USER, self.VHOST, self.PORT)) + self._consumer_tag = None + self._connection = None + self._consuming = False + self._channel = None self._parameters = pika.ConnectionParameters( self.HOST, self.PORT,