Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for findJobByUniqueOf (0.08 seconds)

  1. src/main/java/org/codelibs/fess/opensearch/config/exentity/ScheduledJob.java

        }
    
        public boolean isRunning() {
            return ComponentUtil.getJobManager().findJobByUniqueOf(LaJobUnique.of(getId())).map(LaScheduledJob::isExecutingNow).orElse(false);
        }
    
        public void start() {
            ComponentUtil.getJobManager().findJobByUniqueOf(LaJobUnique.of(getId())).ifPresent(job -> {
                job.launchNow();
            }).orElse(() -> {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 11:55:54 GMT 2026
    - 3.6K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/helper/JobHelper.java

         * @return an optional containing the scheduled job if found, empty otherwise
         */
        private OptionalThing<LaScheduledJob> findJobByUniqueOf(final LaJobUnique jobUnique) {
            final JobManager jobManager = ComponentUtil.getJobManager();
            try {
                return jobManager.findJobByUniqueOf(jobUnique);
            } catch (final Exception e) {
                return OptionalThing.empty();
            }
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/app/job/ScriptExecutorJobTest.java

            // JobManager that finds our job
            final JobManager jobManager = new JobManager() {
                @Override
                public OptionalThing<LaScheduledJob> findJobByUniqueOf(final LaJobUnique jobUnique) {
                    return OptionalThing.of(new MinimalLaScheduledJob());
                }
    
                @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 11:55:54 GMT 2026
    - 13.7K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerActionTest.java

                    }
                    return null;
                }
            };
    
            final JobManager mockJobManager = new JobManager() {
                @Override
                public OptionalThing<LaScheduledJob> findJobByUniqueOf(final LaJobUnique jobUnique) {
                    if (jobId.equals(jobUnique.value())) {
                        return OptionalThing.of(mockLaJob);
                    }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 11:55:54 GMT 2026
    - 13K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/opensearch/config/exentity/ScheduledJobTest.java

        private JobManager createMockJobManager(final String expectedJobId, final LaScheduledJob laScheduledJob) {
            return new JobManager() {
                @Override
                public OptionalThing<LaScheduledJob> findJobByUniqueOf(final LaJobUnique jobUnique) {
                    if (expectedJobId.equals(jobUnique.value()) && laScheduledJob != null) {
                        return OptionalThing.of(laScheduledJob);
                    }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 11:55:54 GMT 2026
    - 15.8K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/app/job/ScriptExecutorJob.java

            if (jobExecutor == null) {
                throw new ScheduledJobException("No jobExecutor: " + scriptType);
            }
    
            if (!jobManager.findJobByUniqueOf(LaJobUnique.of(id)).isPresent()) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Job is running: id={}", id);
                }
                return;
            }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 11:55:54 GMT 2026
    - 5.7K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/wizard/AdminWizardAction.java

                final JobManager jobManager = ComponentUtil.getJobManager();
                for (final ScheduledJob scheduledJob : scheduledJobList) {
                    jobManager.findJobByUniqueOf(LaJobUnique.of(scheduledJob.getId())).ifPresent(job -> {
                        job.launchNow();
                    });
                }
                saveInfo(messages -> messages.addSuccessStartCrawlProcess(GLOBAL));
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Jan 10 02:14:37 GMT 2026
    - 16.4K bytes
    - Click Count (0)
Back to Top