docs: def connect(self):
          """Create the low-level AMQP connection to RabbitMQ.
  
          :rtype: pika.adapters.tornado_connection.TornadoConnection
  
          """
          self.set_state(self.STATE_CONNECTING)
          self.handle = tornado_connection.TornadoConnection(
              self._connection_parameters,
              on_open_callback=self.on_open,
              on_open_error_callback=self.on_open_error,
              stop_ioloop_on_close=False,
              custom_ioloop=self.io_loop)