code: def consume(self):  # pragma: no cover
          
          print(' [*] Waiting for logs. To exit press CTRL+C')
          self.channel.basic_consume(self.queue_name, self.callback)
          self.channel.start_consuming()
docs: start consuming rabbitmq messages