- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for addShutdownListener (0.28 sec)
-
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();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 10.2K bytes - Viewed (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) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 25K bytes - Viewed (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; }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 31.4K bytes - Viewed (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();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 10.5K bytes - Viewed (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();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 11.7K bytes - Viewed (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) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 18.8K bytes - Viewed (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();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.6K bytes - Viewed (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(); } @Override
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 22.1K bytes - Viewed (0)