Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for JobExecutor (0.47 sec)

  1. src/test/java/org/codelibs/fess/it/CrawlTestBase.java

                    + ".webConfigIds([\"%s\"] as String[])" + ".jobExecutor(executor).execute();", webCofigId, webCofigId);
        }
    
        protected static String buildFileConfigJobScript(final String fileConfigId) {
            return String.format("return container.getComponent(\"crawlJob\")" + ".logLevel(\"info\")" + ".sessionId(\"%s\")"
                    + ".fileConfigIds([\"%s\"] as String[])" + ".jobExecutor(executor).execute();", fileConfigId, fileConfigId);
        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10K bytes
    - Viewed (0)
  2. 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 {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  3. 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 {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/job/SuggestJobTest.java

                cacheCleared = true;
            }
    
            public boolean isCacheCleared() {
                return cacheCleared;
            }
        }
    
        // Mock JobExecutor implementation
        private class MockJobExecutor extends JobExecutor {
            private boolean hasShutdownListener = false;
    
            @Override
            public void addShutdownListener(ShutdownListener listener) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/util/ComponentUtil.java

    import org.codelibs.fess.helper.ViewHelper;
    import org.codelibs.fess.helper.VirtualHostHelper;
    import org.codelibs.fess.indexer.IndexUpdater;
    import org.codelibs.fess.ingest.IngestFactory;
    import org.codelibs.fess.job.JobExecutor;
    import org.codelibs.fess.ldap.LdapManager;
    import org.codelibs.fess.mylasta.direction.FessConfig;
    import org.codelibs.fess.mylasta.direction.FessProp;
    import org.codelibs.fess.opensearch.client.SearchEngineClient;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/job/CrawlJob.java

                for (final String id : dataConfigIds) {
                    resultBuf.append(' ').append(id);
                }
                resultBuf.append('\n');
            }
    
            if (jobExecutor != null) {
                jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId));
            }
    
            final TimeoutTask timeoutTask = createTimeoutTask();
            try {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.6K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/job/GenerateThumbnailJobTest.java

                return null;
            }
    
            @Override
            public void setResponseCharacterEncoding(String encoding) {
            }
        }
    
        private static class TestJobExecutor extends JobExecutor {
            boolean shutdownListenerAdded = false;
    
            @Override
            public void addShutdownListener(ShutdownListener listener) {
                shutdownListenerAdded = true;
                listener.onShutdown();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  8. src/main/resources/fess_config.properties

    # Script template for job execution.
    job.template.script=return container.getComponent("crawlJob").logLevel("info").webConfigIds([{0}] as String[]).fileConfigIds([{1}] as String[]).dataConfigIds([{2}] as String[]).jobExecutor(executor).execute();
    # Maximum number of crawler processes.
    job.max.crawler.processes=0
    # Default script language for jobs.
    job.default.script=groovy
    # Pattern to filter system properties for jobs.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 05 14:45:37 UTC 2025
    - 54.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java

        /** The key of the configuration. e.g. return container.getComponent("crawlJob").logLevel("info").webConfigIds([{0}] as String[]).fileConfigIds([{1}] as String[]).dataConfigIds([{2}] as String[]).jobExecutor(executor).execute(); */
        String JOB_TEMPLATE_SCRIPT = "job.template.script";
    
        /** The key of the configuration. e.g. 0 */
        String JOB_MAX_CRAWLER_PROCESSES = "job.max.crawler.processes";
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 525.6K bytes
    - Viewed (1)
Back to top