private static final long serialVersionUID = 1L;

    /**
     * Resource type that caused the error
     */
    public enum ResourceType {
        FILE_HANDLE, CONNECTION, MEMORY, DISK_SPACE, QUOTA, LOCK, BUFFER, THREAD_POOL
    }

    private final ResourceType resourceType;
    private final long availableResources;
    private final long requestedResources;

    /**
     * Creates a resource exception
     *

            { "aliases", "allocation", "count", "fielddata", "health", "indices", "master", "nodeattrs", "nodes", "pending_tasks",
                    "plugins", "recovery", "repositories", "thread_pool", "shards", "segments", "snapshots", "templates" };

    // ===================================================================================

# common

# Default script for the crawler (e.g., groovy).
crawler.default.script=groovy
# Number of threads for HTTP crawling.
crawler.http.thread_pool.size=0
# Serializer type for crawler data (e.g., kryo).
crawler.data.serializer=kryo
# Maximum length of site name in documents.
crawler.document.max.site.length=100
# Encoding for site names in documents.

    /**
     * Get the value for the key 'crawler.http.thread_pool.size'. <br>
     * The value is, e.g. 0 <br>
     * comment: Number of threads for HTTP crawling.
     * @return The value of found property. (NotNull: if not found, exception but basically no way)
     */
    String getCrawlerHttpThreadPoolSize();

    /**
     * Get the value for the key 'crawler.http.thread_pool.size' as {@link Integer}. <br>

        }
    }

    /**
     * Sets the thread pool for executing the request.
     *
     * @param threadPool the thread pool
     * @return this CurlRequest instance
     */
    public CurlRequest threadPool(final ForkJoinPool threadPool) {
        this.threadPool = threadPool;
        return this;
    }

    /**
     * The RequestProcessor class processes the HTTP request and handles the response.

        this.analyzer = analyzer;
        return this;
    }

    /**
     * Sets the thread pool.
     * @param threadPool The thread pool.
     * @return This builder instance.
     */
    public SuggesterBuilder threadPool(final ExecutorService threadPool) {
        this.threadPool = threadPool;
        return this;
    }

    /**
     * Sets the thread pool size.

     * @param settings The suggest settings.
     * @param threadPool The thread pool.
     */
    public SuggestIndexer(final Client client, final String index, final ReadingConverter readingConverter,
            final ReadingConverter contentsReadingConverter, final Normalizer normalizer, final SuggestAnalyzer analyzer,
            final SuggestSettings settings, final ExecutorService threadPool) {
        this.client = client;

        this.analyzer = Objects.requireNonNull(analyzer, "analyzer must not be null");
        index = settings.getAsString(SuggestSettings.DefaultKeys.INDEX, StringUtil.EMPTY);
        this.threadPool = Objects.requireNonNull(threadPool, "threadPool must not be null");

        if (logger.isDebugEnabled()) {
            logger.debug("Created suggester instance: index={}", index);
        }
    }

    /**

        ForkJoinPool pool1 = new ForkJoinPool(2);
        ForkJoinPool pool2 = new ForkJoinPool(4);

        // Multiple threadPool calls should work
        request.threadPool(pool1);
        request.threadPool(pool2);

        assertNotNull(request);
    }

    @Test
    public void testOnConnectWithNull() {

        connected = false;
    }

    /**
     * Gets the thread pool from the underlying client.
     *
     * @return The thread pool.
     */
    @Override
    public ThreadPool threadPool() {
        return client.threadPool();
    }

    /**
     * Gets the admin client for cluster and index operations.
     *
     * @return The admin client.
     */
    @Override