assertTrue(createIndexResponse.isAcknowledged());

        // Create suggest settings index
        Settings suggestIndexSettings = Settings.builder().put("number_of_shards", 1).put("number_of_replicas", 0).build();

        createIndexResponse = client.admin().indices().prepareCreate(SUGGEST_INDEX).setSettings(suggestIndexSettings).execute().actionGet();

     */
    public void updateAnalyzer(final Map<String, Object> settings) {
        client.admin()
                .indices()
                .prepareCreate(analyzerSettingsIndexName)
                .setSettings(settings)
                .execute()
                .actionGet(this.settings.getIndicesTimeout());
    }

    /**
     * Deletes the analyzer settings.
     */

                            getUpdateAlias(index));
                }

                client.admin()
                        .indices()
                        .prepareCreate(indexName)
                        .setSettings(settingsSource, XContentType.JSON)
                        .setMapping(mappingSource)
                        .addAlias(new Alias(getSearchAlias(index)))
                        .addAlias(new Alias(getUpdateAlias(index)))

                try {
                    client.admin()
                            .indices()
                            .prepareCreate(settingsIndexName)
                            .setSettings(loadIndexSettings(), XContentType.JSON)
                            .execute()
                            .actionGet(getIndicesTimeout());
                } catch (final IOException e) {

                empty = true;
                final CreateIndexResponse response = client.admin()
                        .indices()
                        .prepareCreate(actualIndex)
                        .setSettings(loadIndexSettings(), XContentType.JSON)
                        .execute()
                        .actionGet(settings.getIndicesTimeout());
                if (!response.isAcknowledged()) {

    taskRunner.newQueue().execute(name = connectionName, block = readerRunnable)
  }

  /** Merges [settings] into this peer's settings and sends them to the remote peer. */
  @Throws(IOException::class)
  fun setSettings(settings: Settings) {
    writer.withLock {
      withLock {
        if (isShutdown) {
          throw ConnectionShutdownException()
        }
        okHttpSettings.merge(settings)
      }

    private fun writeResponse(
      stream: Http2Stream,
      request: RecordedRequest,
      response: MockResponse,
    ) {
      val settings = response.settings
      stream.connection.setSettings(settings)

      val bodyDelayNanos = response.bodyDelayNanos
      val trailers = response.trailers
      val body = response.body
      val socketHandler = response.socketHandler
      val outFinished = (

    }

    /**
     * Sets the configuration settings for the search engine.
     *
     * @param settings map of configuration key-value pairs
     */
    public void setSettings(final Map<String, String> settings) {
        this.settings = settings;
    }

    /**
     * Gets the current cluster health status.
     *
     * @return the cluster health status name
     */