/**
     * The FTP client configuration.
     */
    protected FTPClientConfig ftpClientConfig;

    /**
     * The queue of FTPClient instances.
     */
    protected final Queue<FTPClient> ftpClientQueue = new ConcurrentLinkedQueue<>();

    /**
     * The active external host.
     */
    protected String activeExternalHost;

    /**

		<arg>crawlerConfig</arg>
	</component>

	<component name="crawlerConfig" class="org.codelibs.fess.crawler.util.OpenSearchCrawlerConfig">
		<property name="queueIndex">"fess_crawler.queue"</property>
		<property name="queueShards">5</property>
		<property name="queueReplicas">1</property>
		<property name="dataIndex">"fess_crawler.data"</property>
		<property name="dataShards">5</property>

# Number of primary shards for crawler queue index.
index.document.crawler.queue.number_of_shards=10
# Number of primary shards for crawler data index.
index.document.crawler.data.number_of_shards=10
# Number of primary shards for crawler filter index.
index.document.crawler.filter.number_of_shards=10
# Number of replicas for crawler queue index.
index.document.crawler.queue.number_of_replicas=1

        final long elapsed = (System.nanoTime() - start) / 1000000;

        assertTrue("file:// URLs should not be delayed", elapsed < 50);
    }

    /**
     * Test that null URL queue is handled gracefully
     */
    public void test_nullUrlQueue() {
        final HostIntervalController controller = new HostIntervalController();
        controller.delayMillisBeforeProcessing = 1000L;

                return true;
            }
        }
        return false;
    }

    /**
     * Processes the result data and stores it along with child URLs.
     *
     * @param urlQueue the URL queue entry
     * @param responseData the response data
     * @param resultData the result data
     */
    protected void processResult(final UrlQueue<?> urlQueue, final ResponseData responseData, final ResultData resultData) {

    /** Atomic flag indicating whether the crawler is currently running. */
    private static AtomicBoolean running = new AtomicBoolean(false);

    /** Thread-safe queue for collecting error messages during crawling operations. */
    private static Queue<String> errors = new ConcurrentLinkedQueue<>();

    /** Injected search engine client for OpenSearch operations. */
    @Resource

        }
    }

    /**
     * Stores a failure URL with error information for later analysis.
     *
     * @param crawlerContext the crawler context
     * @param urlQueue the URL queue containing the failed URL
     * @param errorName the name/type of the error
     * @param e the throwable that caused the failure
     * @return the stored FailureUrl entity
     */

a.ActiveXObject("Microsoft.XMLHTTP")}return function(){return b}}(),f=function(a,b){var c=e();c&&(c.open("GET",a,!0),c.onreadystatechange=function(){4!==c.readyState||200!==c.status&&304!==c.status||b(c.responseText)},4!==c.readyState&&c.send(null))};if(c.ajax=f,c.queue=d,c.regex={media:/@media[^\{]+\{([^\{\}]*\{[^\}\{]*\})+/gi,keyframes:/@(?:\-(?:o|moz|webkit)\-)?keyframes[^\{]+\{(?:[^\{\}]*\{[^\}\{]*\})+[^\}]*\}/gi,urls:/(url\()['"]?([^\/\)'"][^:\)'"]+)['"]?(\))/g,findStyles:/@media *([^\{]+)\{([\S\s]+?)$/,only...

     * Get the value for the key 'logging.search.max.queue.size'. <br>
     * The value is, e.g. 10000 <br>
     * comment: Maximum queue size for search logging.
     * @return The value of found property. (NotNull: if not found, exception but basically no way)
     */
    String getLoggingSearchMaxQueueSize();

    /**
     * Get the value for the key 'logging.search.max.queue.size' as {@link Integer}. <br>

labels.dict_synonym_link_delete=Löschen
labels.dict_synonym_link_details=Details
labels.dict_synonym_link_download=Herunterladen
labels.dict_synonym_link_upload=Hochladen
labels.dict_synonym_source=Quelle
labels.dict_synonym_target=Ziel
labels.dict_synonym_button_download=Herunterladen
labels.dict_synonym_button_upload=Hochladen
labels.dict_synonym_file=Synonymdatei