code: def start_server(self):
          
          self._stopped.clear()
          if not self._connection or self._connection.is_closed:
              self._create_connection()
          while not self._stopped.is_set():
              try:
                  # Check our connection for errors.
                  self._connection.check_for_errors()
                  self._update_consumers()
              except amqpstorm.AMQPError as why:
                  # If an error occurs, re-connect and let update_consumers
                  # re-open the channels.
                  LOGGER.warning(why)
                  self._stop_consumers()
                  self._create_connection()
              time.sleep(1)
docs: Start the RPC Server.
  
          :return: