"seiner", "seines", "selbst", "sich", "sie", "ihnen", "sind", "so", "solche", "solchem", "solchen", "solcher", "solches", "soll", "sollte", "sondern", "sonst", "über", "um", "und", "uns", "unse", "unsem", "unsen", "unser", "unses", "unter", "viel", "vom", "von", "vor", "während", "war", "waren", "warst", "was", "weg", "weil", "weiter", "welche", "welchem", "welchen", "welcher", "welches", "wenn", "werde", "werden", "wie", "wieder", "will", "wir", "wird", "wirst", "wo", "wollen", "wollte", "würde",...

"seiner", "seines", "selbst", "sich", "sie", "ihnen", "sind", "so", "solche", "solchem", "solchen", "solcher", "solches", "soll", "sollte", "sondern", "sonst", "über", "um", "und", "uns", "unse", "unsem", "unsen", "unser", "unses", "unter", "viel", "vom", "von", "vor", "während", "war", "waren", "warst", "was", "weg", "weil", "weiter", "welche", "welchem", "welchen", "welcher", "welches", "wenn", "werde", "werden", "wie", "wieder", "will", "wir", "wird", "wirst", "wo", "wollen", "wollte", "würde",...

     *
     * @param crawlerConfig the OpenSearch crawler configuration
     */
    public FessUrlQueueService(final OpenSearchCrawlerConfig crawlerConfig) {
        super(crawlerConfig);
    }

    /**
     * Fetches URL queue list for the specified session with configurable ordering strategy.
     * Supports sequential (default) and random ordering based on crawling configuration.
     *
     * @param sessionId the crawling session identifier

     */
    public StemmerOverrideService() {
        // Default constructor
    }

    /**
     * Retrieves a paginated list of stemmer override items from the specified dictionary.
     *
     * This method fetches stemmer override entries with pagination support, updating
     * the provided pager with the current page state and navigation information.
     *
     * @param dictId The ID of the stemmer override dictionary to query

                log(buf);
            }
        });
    }

    /**
     * Marks statistics tracking as complete for the specified crawler object.
     * Decrements the reference count and if it reaches zero, removes the
     * statistics object from cache and outputs the final statistics.
     *
     * @param keyObj the crawler object to complete tracking for
     */
    public void done(final Object keyObj) {

     */
    @Resource
    protected FessConfig fessConfig;

    /**
     * Retrieves a paginated list of character mapping items from the specified dictionary.
     * <p>
     * This method fetches character mapping items with pagination support and updates
     * the pager with the current page information including total count and page ranges.
     * </p>
     *

     */
    public void addEventHandler(final String eventName, final Consumer<EventInfo> handler) {
        eventHandlers.computeIfAbsent(eventName, k -> new ArrayList<>()).add(handler);
    }

    /**
     * Fetches new events from OpenSearch that were created after the last check time.
     *
     * @return the list of new events.
     */
    protected List<EventInfo> fetchNewEvents() {

        helper.poll();
        assertTrue(heartbeatCalled.get());
        assertTrue(cleanupCalled.get());
    }

    @Test
    public void test_poll_dispatchesEvents() {
        // Verify that poll fetches events and dispatches them
        final AtomicInteger dispatchCount = new AtomicInteger(0);
        final CoordinatorHelper helper = new CoordinatorHelper() {
            @Override

        if (rejected != null) {
            return rejected;
        }
        return searchDocuments(query, fields, extraQueries);
    }

    /**
     * Fetches full document content for the given document IDs.
     *
     * @param docIds the document IDs to fetch
     * @return list of documents with full content
     */