}
        };

        scheduledJobs.add(job1);
        scheduledJobs.add(job2);
        scheduledJobs.add(job3);

        ComponentUtil.register(new ScheduledJobBhv() {
            @Override
            public void selectCursor(CBCall<ScheduledJobCB> cbLambda, EntityRowHandler<ScheduledJob> entityLambda) {
                for (ScheduledJob job : scheduledJobs) {
                    entityLambda.handle(job);

    }

    /**
     * Gets a scheduled job by its ID.
     * @param id The ID of the scheduled job.
     * @return An optional entity of the scheduled job.
     */
    public OptionalEntity<ScheduledJob> getScheduledJob(final String id) {
        return scheduledJobBhv.selectByPK(id);
    }

    /**
     * Deletes a scheduled job.
     * @param scheduledJob The scheduled job to delete.
     */

import jakarta.annotation.Resource;

/**
 * Service class for managing job logs in the Fess application.
 * Provides functionality to create, read, update, and delete job log entries,
 * as well as manage job status and perform cleanup operations.
 */
public class JobLogService {

    /**
     * Behavior class for job log database operations.
     */
    @Resource
    protected JobLogBhv jobLogBhv;

    /**

import org.lastaflute.core.time.TimeManager;
import org.lastaflute.job.LaCron;
import org.lastaflute.job.LaJob;
import org.lastaflute.job.LaJobRunner;
import org.lastaflute.job.LaJobScheduler;

import jakarta.annotation.Resource;

/**
 * Job scheduler for managing all scheduled jobs in Fess.
 * Implements LaJobScheduler to handle job scheduling and execution.
 */
public class AllJobScheduler implements LaJobScheduler {

	</component>

	<!-- Jobs -->
	<component name="crawlJob" class="org.codelibs.fess.job.CrawlJob" instance="prototype">
	</component>
	<component name="suggestJob" class="org.codelibs.fess.job.SuggestJob" instance="prototype">
	</component>
	<component name="aggregateLogJob" class="org.codelibs.fess.job.AggregateLogJob" instance="prototype">
	</component>

import org.dbflute.optional.OptionalThing;
import org.lastaflute.job.JobManager;
import org.lastaflute.job.LaCron;
import org.lastaflute.job.LaJobRuntime;
import org.lastaflute.job.LaScheduledJob;
import org.lastaflute.job.key.LaJobUnique;
import org.lastaflute.job.subsidiary.CronParamsSupplier;

/**
 * Helper class for managing scheduled jobs within the Fess system.

            if (jobRuntime != null) {
                final ScheduledJob job = (ScheduledJob) jobRuntime.getParameterMap().get(Constants.SCHEDULED_JOB);
                if (job != null) {
                    prop.setProperty("job.runtime.id", job.getId());
                    prop.setProperty("job.runtime.name", job.getName());
                }
            }
            prop.store(out, cmdList.toString());

│   │   └── api/               # API controllers
│   ├── service/               # Business logic services
│   ├── pager/                 # Pagination handlers
│   └── job/                   # Background jobs
├── api/                       # REST API infrastructure
├── opensearch/                # DBFlute integration for OpenSearch
│   ├── config/                # Config index (crawl configs, schedules)

        } finally {
            if (timeoutTask != null && !timeoutTask.isCanceled()) {
                timeoutTask.cancel();
            }
        }

        return resultBuf.toString();

    }

    /**
     * Gets the count of currently running crawler jobs.
     * This method queries the scheduled jobs to count active crawler processes.

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.exception;

/**
 * Exception thrown when an error occurs during job processing.
 * This exception is used to indicate problems that arise during
 * the execution or processing of jobs in the system.
 */
public class JobProcessingException extends FessSystemException {

    private static final long serialVersionUID = 1L;

    /**