ComponentUtil.doInitProcesses(Runnable::run);

        assertEquals(2, executionOrder.size());
        assertEquals("first", executionOrder.get(0));
        assertEquals("second", executionOrder.get(1));

        ComponentUtil.processAfterContainerInit(() -> executionOrder.add("third"));
        assertEquals(2, executionOrder.size());
    }

    @Test
    public void test_available_withSystemHelper() {

        assertEquals("fess-crawler-smbj", list.get(1).getName());
        assertEquals("14.15.0", list.get(1).getVersion());
        assertEquals("plugin/repo3/fess-crawler-smbj/14.15.0/fess-crawler-smbj-14.15.0.jar", list.get(1).getUrl());
    }

    @Test
    public void test_getArtifactFromFileName1() {

        thread.start();
        thread.join(1000);

        assertEquals(2, callbackResults.size());
        assertEquals("callback1", callbackResults.get(0));
        assertEquals("callback2", callbackResults.get(1));
    }

    @Test
    public void test_run_bufferSizeLimit() throws InterruptedException {
        StringBuilder inputBuilder = new StringBuilder();
        for (int i = 1; i <= 15; i++) {

        value = "a=b\n1=2";
        paramMap = ParameterUtil.parse(value);
        assertEquals(2, paramMap.size());
        assertEquals("b", paramMap.get("a"));
        assertEquals("2", paramMap.get("1"));

        value = "a=";
        paramMap = ParameterUtil.parse(value);
        assertEquals(1, paramMap.size());
        assertEquals("", paramMap.get("a"));

        value = "a";

        chain.update(user2);
        chain.update(user3);

        assertEquals(3, chain.updateCalls.size());
        assertEquals(user1, chain.updateCalls.get(0));
        assertEquals(user2, chain.updateCalls.get(1));
        assertEquals(user3, chain.updateCalls.get(2));
    }

    // Test update with exception handling
    @Test
    public void test_update_withException() {

        assertEquals(5000L, events.get(0).createdTime);
        assertEquals("web_config", events.get(0).data);
        assertEquals("dict_updated", events.get(1).name);
        assertEquals("node3@host3", events.get(1).instanceId);
        assertEquals(6000L, events.get(1).createdTime);
    }

    @Test
    public void test_fetchNewEvents_updatesLastEventCheckTime() {
        setupMockFessConfig();

        List<LogNotificationEvent> events = helper.drainAll();
        assertEquals(2, events.size());
        assertEquals("message1", events.get(0).getMessage());
        assertEquals("message2", events.get(1).getMessage());
    }

    @Test
    public void test_drainAll_empty() {
        LogNotificationHelper helper = new LogNotificationHelper();
        List<LogNotificationEvent> events = helper.drainAll();

        docList.add(doc1);
        docList.add(doc2);

        assertEquals(2, docList.size());
        assertEquals(doc1, docList.get(0));
        assertEquals(doc2, docList.get(1));

        docList.addContentSize(500);
        docList.addProcessingTime(250);

        assertEquals(500, docList.getContentSize());
        assertEquals(250, docList.getProcessingTime());

        thread.start();
        thread.join(1000);

        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

        assertEquals(2, urlList.size());
        assertEquals("http://www.example.com", urlList.get(0).getUrl());
        assertEquals("http://www.test.com", urlList.get(1).getUrl());

        urlList.clear();
        urlList.add(RequestDataBuilder.newRequestData().get().url("feed://www.example.com").build());