// Test error message constants
        assertEquals("{errors.front_header}", FessMessages.ERRORS_front_header);
        assertEquals("{errors.front_footer}", FessMessages.ERRORS_front_footer);
        assertEquals("{errors.front_prefix}", FessMessages.ERRORS_front_prefix);
        assertEquals("{errors.front_suffix}", FessMessages.ERRORS_front_suffix);
        assertEquals("{errors.header}", FessMessages.ERRORS_HEADER);

    }

    // Test error handling in doCrawl
    public void test_doCrawl_withErrors() {
        // Clear any previous errors
        try {
            Field errorsField = Crawler.class.getDeclaredField("errors");
            errorsField.setAccessible(true);
            Queue<String> errors = (Queue<String>) errorsField.get(null);
            errors.clear();
        } catch (Exception e) {

    /**
     * Adds an error message to the error queue for later processing.
     * This method is thread-safe and can be called from multiple crawler threads.
     *
     * @param msg the error message to add; ignored if null or blank
     */
    public static void addError(final String msg) {
        if (StringUtil.isNotBlank(msg)) {
            errors.offer(msg);
        }
    }

    /**

     * Pre-processes API requests by checking access authorization before executing the action.
     * If access is not allowed, returns an unauthorized error response.
     *
     * @param runtime the action runtime context containing request information
     * @return ActionResponse with unauthorized error if access denied, otherwise delegates to parent
     */
    @Override
    public ActionResponse godHandPrologue(final ActionRuntime runtime) {

        // Verify result contains error message
        assertNotNull(result);
        assertTrue(result.contains("Illegal state in search log processing"));
        assertTrue(result.endsWith("\n"));
    }

    public void test_execute_multipleErrors() {
        // Test with multiple calls to execute() with errors
        SearchLogHelper mockSearchLogHelper = new SearchLogHelper() {

        Supplier<Object> supplier = () -> {
            throw new RuntimeException("Test exception");
        };

        monitorTarget.append(buf, "errorKey", supplier);
        assertEquals("\"errorKey\":null", buf.toString());
    }

    // Test append method with Boolean value (other object type)
    public void test_append_booleanValue() {
        StringBuilder buf = new StringBuilder();

        // We can't test isTarget properly without container,
        // but we can verify conditions are added
        assertNotNull(emptyGenerator);

        // Test that multiple conditions can be added without errors
        emptyGenerator.addCondition("type", "document");
        emptyGenerator.addCondition("mime", "text/.*");
    }

    public void test_setDirectoryNameLength() {
        // Initialize without container

     *
     * @param is the input source containing the GSA configuration XML
     * @throws GsaConfigException if parsing fails due to XML format issues or other errors
     */
    public void parse(final InputSource is) {
        try {
            final SAXParserFactory factory = SAXParserFactory.newInstance();

    protected long executeTime;

    /** Total number of processed documents */
    protected long documentSize;

    /** Maximum number of indexer errors allowed */
    protected int maxIndexerErrorCount = 0;

    /** Maximum number of general errors allowed before termination */
    protected int maxErrorCount = 2;

    /** List of finished crawler session IDs for cleanup */

    }

    /**
     * Indexes suggest data from documents.
     *
     * @param success A callback for successful indexing.
     * @param error   A callback for indexing errors.
     */
    public void indexFromDocuments(final Consumer<Boolean> success, final Consumer<Throwable> error) {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();