Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 16 for dequeue (0.04 seconds)

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

  1. src/main/resources/fess_message_fr.properties

    errors.failed_to_delete_doc_in_admin = Échec de la suppression d'un document.
    errors.failed_to_send_testmail=Échec de l'envoi d'un e-mail de test.
    errors.invalid_query_unknown = La requête spécifiée a une condition inconnue.
    errors.invalid_query_parse_error = La requête donnée n'est pas valide.
    errors.invalid_query_sort_value = Le tri spécifié {0} n'est pas valide.
    errors.invalid_query_unsupported_sort_field = Le tri spécifié {0} n'est pas pris en charge.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 14.1K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/crawler/util/FessCrawlerConfig.java

     * index names, shard counts, and replica counts for queue, data, and filter indices.
     */
    public class FessCrawlerConfig extends OpenSearchCrawlerConfig {
    
        /**
         * Default constructor.
         */
        public FessCrawlerConfig() {
            super();
        }
    
        /**
         * Gets the name of the queue index for the crawler.
         *
         * @return the queue index name
         */
        @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/exec/CrawlerTest.java

                errorsField.setAccessible(true);
                Queue<String> errors = (Queue<String>) errorsField.get(null);
                errors.clear();
            } catch (Exception e) {
                // Ignore if field doesn't exist
            }
    
            // Add some errors to the queue
            Crawler.addError("Error 1");
            Crawler.addError("Error 2");
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 30.8K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/crawler/service/FessUrlQueueService.java

    import org.opensearch.index.query.functionscore.RandomScoreFunctionBuilder;
    import org.opensearch.search.sort.SortBuilders;
    import org.opensearch.search.sort.SortOrder;
    
    /**
     * Fess-specific URL queue service that extends OpenSearch URL queue functionality.
     * This service provides customized URL fetching strategies including sequential and random ordering
     * based on crawling configuration parameters.
     */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 4K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/crawler/interval/FessIntervalController.java

        /**
         * Gets the delay time in milliseconds when there are no URLs in the queue.
         *
         * @return the delay time in milliseconds when no URLs are available
         */
        public long getDelayMillisAtNoUrlInQueue() {
            return delayMillisAtNoUrlInQueue;
        }
    
        /**
         * Sets the delay time in milliseconds when there are no URLs in the queue.
         *
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Nov 19 07:09:17 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

        /**
         * Maximum size of the thumbnail generation task queue.
         */
        protected int thumbnailTaskQueueSize = 10000;
    
        /**
         * Number of tasks to process in bulk operations.
         */
        protected int thumbnailTaskBulkSize = 100;
    
        /**
         * Timeout in milliseconds for thumbnail task queue operations.
         */
        protected long thumbnailTaskQueueTimeout = 10 * 1000L;
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jan 01 12:47:47 GMT 2026
    - 27.2K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

        /** Service for managing crawled document data */
        @Resource
        protected DataService<OpenSearchAccessResult> dataService;
    
        /** Service for managing URL crawling queue */
        @Resource
        protected UrlQueueService<OpenSearchUrlQueue> urlQueueService;
    
        /** Service for URL filtering operations */
        @Resource
        protected UrlFilterService urlFilterService;
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  8. src/main/resources/crawler_opensearch+crawlerConfig.xml

    	"http://dbflute.org/meta/lastadi10.dtd">
    <components namespace="fessCrawler">
    	<component name="crawlerConfig" class="org.codelibs.fess.crawler.util.FessCrawlerConfig">
    		<property name="queueIndex">"fess_crawler.queue"</property>
    		<property name="queueShards">5</property>
    		<property name="queueReplicas">1</property>
    		<property name="dataIndex">"fess_crawler.data"</property>
    		<property name="dataShards">5</property>
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Oct 30 05:29:49 GMT 2025
    - 756 bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/thumbnail/ThumbnailManagerTest.java

            docMap.put("_id", "docid1");
    
            boolean result = thumbnailManager.offer(docMap);
            assertFalse(result);
        }
    
        // Test offer with full queue
        @Test
        public void test_offer_fullQueue() {
            thumbnailManager.setThumbnailTaskQueueSize(1);
            thumbnailManager.init();
    
            TestThumbnailGenerator generator = new TestThumbnailGenerator();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 20.4K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java

                throw e;
            }
            saveInfo(messages -> messages.addSuccessStartedDataUpdate(GLOBAL));
            return redirect(getClass());
        }
    
        /**
         * Clears all crawler indices including queue, data, and filter indices.
         *
         * @param form the action form (validated but not used for configuration)
         * @return HTML response redirecting to the maintenance page
         */
        @Execute
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 23K bytes
    - Click Count (0)
Back to Top