Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for selectCursor (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/test/java/org/codelibs/fess/job/CrawlJobTest.java

            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);
                    }
                }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 25K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/job/CrawlJob.java

        protected int getRunningJobCount() {
            final AtomicInteger counter = new AtomicInteger(0);
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            ComponentUtil.getComponent(ScheduledJobBhv.class).selectCursor(cb -> {
                cb.query().setAvailable_Equal(Constants.T);
                cb.query().setCrawler_Equal(Constants.T);
            }, scheduledJob -> {
                if (fessConfig.isSchedulerTarget(scheduledJob.getTarget())) {
    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)
  3. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

            final long timeout = fessConfig.getIndexBackupLogLoadTimeoutAsInteger().longValue();
            return writer -> {
                final SearchLogBhv bhv = ComponentUtil.getComponent(SearchLogBhv.class);
                bhv.selectCursor(cb -> {
                    cb.query().matchAll();
                    cb.query().addOrderBy_RequestedAt_Asc();
                }, new LogEntityRowHandler<SearchLog>() {
                    @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Nov 24 02:07:40 GMT 2025
    - 32.1K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/app/service/ScheduledJobService.java

            });
        }
    
        /**
         * Starts all available scheduled jobs.
         * @param cron The cron scheduler.
         */
        public void start(final LaCron cron) {
            scheduledJobBhv.selectCursor(cb -> {
                cb.query().setAvailable_Equal(Constants.T);
                cb.query().addOrderBy_SortOrder_Asc();
                cb.query().addOrderBy_Name_Asc();
            }, scheduledJob -> {
                try {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/app/service/BadWordService.java

            try {
                final List<String> list = new ArrayList<>();
                list.add("BadWord");
                csvWriter.writeValues(list);
    
                badWordBhv.selectCursor(cb -> cb.query().matchAll(), new EntityRowHandler<BadWord>() {
                    @Override
                    public void handle(final BadWord entity) {
                        final List<String> list = new ArrayList<>();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 8.6K bytes
    - Click Count (0)
Back to Top