code: def open(self):
          
          LOGGER.debug('Connection Opening')
          self.set_state(self.OPENING)
          self._exceptions = []
          self._channels = {}
          self._last_channel_id = None
          self._io.open()
          self._send_handshake()
          self._wait_for_connection_state(state=Stateful.OPEN)
          self.heartbeat.start(self._exceptions)
          LOGGER.debug('Connection Opened')
docs: Open Connection.
  
          :raises AMQPConnectionError: Raises if the connection
                                       encountered an error.