- Sort Score
- Num 10 results
- Language All
Results 1 - 9 of 9 for addShutdownListener (0.08 seconds)
-
src/test/java/org/codelibs/fess/job/JobExecutorTest.java
callCount.addAndGet(10); } }; // Add first listener jobExecutor.addShutdownListener(listener1); assertEquals(listener1, jobExecutor.shutdownListener); // Replace with second listener jobExecutor.addShutdownListener(listener2); assertEquals(listener2, jobExecutor.shutdownListener); // Verify only second listener is called
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 9.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/CrawlJobTest.java
final List<JobExecutor.ShutdownListener> shutdownListeners = new ArrayList<>(); JobExecutor mockJobExecutor = new JobExecutor() { @Override public void addShutdownListener(ShutdownListener listener) { shutdownListeners.add(listener); } @Override public Object execute(String scriptType, String script) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 25K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/SuggestJobTest.java
private class MockJobExecutor extends JobExecutor { private boolean hasShutdownListener = false; @Override public void addShutdownListener(ShutdownListener listener) { hasShutdownListener = true; super.addShutdownListener(listener); } @Override public Object execute(String scriptType, String script) { return null; }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 31.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/PythonJobTest.java
} } private static class TestJobExecutor extends JobExecutor { boolean shutdownListenerAdded = false; @Override public void addShutdownListener(ShutdownListener listener) { shutdownListenerAdded = true; // Optionally execute the listener to test its behavior listener.onShutdown(); } @OverrideCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 22.2K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/GenerateThumbnailJobTest.java
} } private static class TestJobExecutor extends JobExecutor { boolean shutdownListenerAdded = false; @Override public void addShutdownListener(ShutdownListener listener) { shutdownListenerAdded = true; listener.onShutdown(); } @Override public Object execute(String scriptType, String script) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 19K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/impl/ScriptExecutorTest.java
// Add first listener TestShutdownListener listener1 = new TestShutdownListener(); scriptExecutor.addShutdownListener(listener1); // Add second listener (should replace first) TestShutdownListener listener2 = new TestShutdownListener(); scriptExecutor.addShutdownListener(listener2); // Call shutdown scriptExecutor.shutdown();Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 10.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/SuggestJob.java
sessionId = RandomStringUtils.randomAlphabetic(15); } resultBuf.append("Session Id: ").append(sessionId).append("\n"); if (jobExecutor != null) { jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId)); } final TimeoutTask timeoutTask = createTimeoutTask(); try { executeSuggestCreator();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 10.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java
sessionId = RandomStringUtils.randomAlphabetic(15); } resultBuf.append("Session Id: ").append(sessionId).append("\n"); if (jobExecutor != null) { jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId)); } final TimeoutTask timeoutTask = createTimeoutTask(); try { executeThumbnailGenerator();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 11.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/CrawlJob.java
resultBuf.append(' ').append(id); } resultBuf.append('\n'); } if (jobExecutor != null) { jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId)); } final TimeoutTask timeoutTask = createTimeoutTask(); try { executeCrawler();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 19.6K bytes - Click Count (0)