def create_connection(self):
        attempts = 0
        while True:
            attempts += 1
            try:
                self.connection = Connection('127.0.0.1', 'guest', 'guest')
                break
            except amqpstorm.AMQPError as why:
                LOGGER.exception(why)
                if self.max_retries and attempts > self.max_retries:
                    break
                time.sleep(min(attempts * 2, 30))
            except __HOLE__:
                break
dataset/ETHPy150Open eandersson/amqpstorm/examples/robust_consumer.py/Consumer.create_connection