List<LogNotificationEvent> first = helper.drainAll();
        assertEquals(1, first.size());
        List<LogNotificationEvent> second = helper.drainAll();
        assertTrue(second.isEmpty());
    }

    @Test
    public void test_offer_bufferCapacity() {
        LogNotificationHelper helper = new LogNotificationHelper();

        assertEquals(2, callbackResults.size());
        assertEquals("integration test", callbackResults.get(0));
        assertEquals("second line", callbackResults.get(1));

        String output = thread.getOutput();
        assertTrue(output.contains("integration test"));
        assertTrue(output.contains("second line"));
    }

    @Test
    public void test_defaultBufferSizeConstant() throws IOException {

        response.getWriter()
                .write("{\"error\":\"rate_limit_exceeded\",\"message\":\"Too many requests. Please retry after " + retryAfterSeconds
                        + " seconds.\",\"retry_after\":" + retryAfterSeconds + "}");
    }

## Issues/Questions

[discuss.codelibs.org](https://discuss.codelibs.org/c/FessEN/)

## Getting Started

There are 2 ways to try Fess. The first is to download and install yourself. The second is to use [Docker](https://www.docker.com/products/docker-engine).

### Download and Install/Run

        String input = "first\nsecond\nthird";
        InputStream is = new ByteArrayInputStream(input.getBytes(StandardCharsets.UTF_8));

        InputStreamThread thread = new InputStreamThread(is, StandardCharsets.UTF_8, 10, null);
        thread.start();
        thread.join(1000);

        String output = thread.getOutput();
        assertEquals("first\nsecond\nthird\n", output);
    }

    @Test

    protected final ConcurrentHashMap<String, JobProcess> runningProcessMap = new ConcurrentHashMap<>();

    /** Timeout in seconds for process destruction */
    protected int processDestroyTimeout = 10;

    /** Timeout in seconds for stream closing operations */
    protected int streamCloseTimeout = 10;

    /**
     * Default constructor for ProcessHelper.

        String first = "first";
        String second = "second";
        String componentName = "testComponent";

        ComponentUtil.register(first, componentName);
        String retrieved1 = ComponentUtil.getComponent(componentName);
        assertSame(first, retrieved1);

        ComponentUtil.register(second, componentName);
        String retrieved2 = ComponentUtil.getComponent(componentName);

        assertEquals("Store2", names[1]);
        assertEquals(1, loadCount[0]);

        // Second immediate call should use cache
        names = testFactory.getDataStoreNames();
        assertEquals(2, names.length);
        assertEquals(1, loadCount[0]); // Should not increment

        // Simulate time passing (more than 60 seconds)
        testFactory.lastLoadedTime = System.currentTimeMillis() - 61000L;

            bulkDelete.add(client.prepareDelete().setIndex(indexName).setId(docId));
        }
        bulkDelete.execute().actionGet(fessConfig.getIndexSearchTimeout());

        // Delete any remaining events beyond the search size limit (discard overflow)
        try {
            client.deleteByQuery(indexName, QueryBuilders.termQuery("hostname", hostname));
        } catch (final Exception e) {

        InvertibleCryptographer first = securityResourceProvider.providePrimaryInvertibleCryptographer();
        InvertibleCryptographer second = securityResourceProvider.providePrimaryInvertibleCryptographer();

        assertNotNull(first);
        assertNotNull(second);
        assertSame(first, second);
        assertSame(invertibleCryptographer, first);
    }

    @Test