def METHOD_NAME(self):
    for i in range(self.config["retry_limit"]):
        try:
            return pika.BlockingConnection(self.params)
        except Exception as e:
            logging.warning(e, exc_info=True)
            logging.warning(f"RabbitMQ Connection Failed. Retrying in 30s ({i + 1}/{self.config['retry_limit']})")
            time.sleep(30)
    return None