code: 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 KeyboardInterrupt:
                  break
docs: Create a connection.
  
          :return: