Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for queued (0.03 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

        /**
         * QueueHolder holds the waiting and crawling queues.
         */
        protected static class QueueHolder {
            /**
             * Constructs a new QueueHolder.
             */
            public QueueHolder() {
                // Default constructor
            }
    
            /**
             * The queue for URLs waiting to be crawled.
             */
            protected Queue<OpenSearchUrlQueue> waitingQueue = new ConcurrentLinkedQueue<>();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (1)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

            }
            log(logHelper, LogType.FINISHED_THREAD, crawlerContext);
        }
    
        /**
         * Adds sitemaps from robots.txt to the crawling queue.
         * @param urlQueue The URL queue to add sitemaps to.
         */
        protected void addSitemapsFromRobotsTxt(final UrlQueue<?> urlQueue) {
            final String[] sitemaps = crawlerContext.removeSitemaps();
            if (sitemaps != null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

     *   crawler.close();
     * </pre>
     */
    public class Crawler implements Runnable, AutoCloseable {
    
        private static final Logger logger = LogManager.getLogger(Crawler.class);
    
        /**
         * Service for managing URL queues during crawling.
         */
        @Resource
        protected UrlQueueService<UrlQueue<?>> urlQueueService;
    
        /**
         * Service for managing access result data.
         */
        @Resource
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/impl/LogHelperImpl.java

     *   <li>Getting content</li>
     *   <li>Handling redirects</li>
     *   <li>Processing responses</li>
     *   <li>Handling exceptions during crawling and child URL processing</li>
     *   <li>Handling cases where no URL is in the queue</li>
     *   <li>Handling cases where no response processor or rule is found</li>
     *   <li>Handling system errors</li>
     * </ul>
     *
     * <p>
     * Each logging method checks the log level before logging the message.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java

        /**
         * The FTP client configuration.
         */
        protected FTPClientConfig ftpClientConfig;
    
        /**
         * The queue of FTPClient instances.
         */
        protected final Queue<FTPClient> ftpClientQueue = new ConcurrentLinkedQueue<>();
    
        /**
         * The active external host.
         */
        protected String activeExternalHost;
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java

                    return true;
                }
            }
            return false;
        }
    
        /**
         * Processes the result data and stores it along with child URLs.
         *
         * @param urlQueue the URL queue entry
         * @param responseData the response data
         * @param resultData the result data
         */
        protected void processResult(final UrlQueue<?> urlQueue, final ResponseData responseData, final ResultData resultData) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 12.5K bytes
    - Viewed (0)
Back to top