docs: def run(self):
          """
          consume message from channel on the consuming thread.
          """
          LOGGER.debug("rabbitmq.Service.run")
          try:
              self.channel.start_consuming()
          except Exception as e:
              LOGGER.warn("rabbitmq.Service.run - Exception raised while consuming")