Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for OpenSearchUrlQueue (0.3 seconds)

  1. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java

            final OpenSearchUrlQueue urlQueue = new OpenSearchUrlQueue();
            urlQueue.setCreateTime(System.currentTimeMillis());
            urlQueue.setDepth(1);
            urlQueue.setMethod("GET");
            urlQueue.setSessionId("id1");
            urlQueue.setUrl("http://www.id1.com/");
    
            urlQueueService.insert(urlQueue);
    
            final OpenSearchUrlQueue urlQueue2 = new OpenSearchUrlQueue();
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Jan 14 23:48:16 GMT 2026
    - 14.5K bytes
    - Click Count (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

         */
        @Override
        public OpenSearchUrlQueue poll(final String sessionId) {
            final QueueHolder queueHolder = getQueueHolder(sessionId);
            final Queue<OpenSearchUrlQueue> waitingQueue = queueHolder.waitingQueue;
            final Queue<OpenSearchUrlQueue> crawlingQueue = queueHolder.crawlingQueue;
    
            OpenSearchUrlQueue urlQueue = waitingQueue.poll();
            if (urlQueue == null) {
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Nov 20 08:40:57 GMT 2025
    - 16.9K bytes
    - Click Count (1)
  3. src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java

            @Override
            public void delete(String sessionId) {
                // Do nothing in test
            }
    
            @Override
            public void deleteAll() {
                // Do nothing in test
            }
    
            @Override
            public void offerAll(String sessionId, List<OpenSearchUrlQueue> list) {
                // Do nothing in test
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 33.6K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

    import org.codelibs.fess.crawler.entity.AccessResult;
    import org.codelibs.fess.crawler.entity.AccessResultData;
    import org.codelibs.fess.crawler.entity.OpenSearchAccessResult;
    import org.codelibs.fess.crawler.entity.OpenSearchUrlQueue;
    import org.codelibs.fess.crawler.service.DataService;
    import org.codelibs.fess.crawler.service.UrlFilterService;
    import org.codelibs.fess.crawler.service.UrlQueueService;
    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)
Back to Top