code: def _close_connection(self, frame_in):
          
          self._set_connection_state(Stateful.CLOSED)
          if frame_in.reply_code != 200:
              reply_text = try_utf8_decode(frame_in.reply_text)
              message = (
                  'Connection was closed by remote server: %s' % reply_text
              )
              exception = AMQPConnectionError(message,
                                              reply_code=frame_in.reply_code)
              self._connection.exceptions.append(exception)
docs: Connection Close.
  
          :param specification.Connection.Close frame_in: Amqp frame.
          :return: