Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for getUrlQueue (0.14 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

            // 同時実行数
            final int numTasks = 100;
            // インターバル
            final Long waittime = 100L;
    
            CrawlingParameterUtil.setUrlQueue(new UrlQueueImpl());
            final UrlQueue q = CrawlingParameterUtil.getUrlQueue();
            for (int i = 0; i < numTasks; i++) {
                q.setUrl("http://example.com");
            }
    
            final HostIntervalController controller = new HostIntervalController();
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java

        protected int[] notModifiedHttpCodes;
    
        @Override
        public void process(final ResponseData responseData) {
            if (isNotModified(responseData)) {
                final UrlQueue<?> urlQueue = CrawlingParameterUtil.getUrlQueue();
                final ResultData resultData = new ResultData();
                resultData.setData(new byte[0]);
                resultData.setEncoding(Constants.UTF_8);
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 9K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/CrawlingParameterUtil.java

        private static final ThreadLocal<DataService<AccessResult<?>>> DATA_SERVICE_THREAD_LOCAL = new ThreadLocal<>();
    
        private CrawlingParameterUtil() {
        }
    
        public static UrlQueue<?> getUrlQueue() {
            return URL_QUEUE_THREAD_LOCAL.get();
        }
    
        public static void setUrlQueue(final UrlQueue<?> urlQueue) {
            if (urlQueue == null) {
                URL_QUEUE_THREAD_LOCAL.remove();
            } else {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java

         * delayBeforeProcessing()
         */
        @Override
        protected void delayBeforeProcessing() {
            final UrlQueue<?> urlQueue = CrawlingParameterUtil.getUrlQueue();
            if (urlQueue == null) {
                return;
            }
    
            final String url = urlQueue.getUrl();
            if (StringUtil.isBlank(url) || url.startsWith("file:")) {
                // not target
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 3K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/crawler/transformer/FessTransformer.java

            String enc = Constants.UTF_8;
            if (StringUtil.isBlank(fessConfig.getCrawlerDocumentFileNameEncoding())) {
                final UrlQueue<?> urlQueue = CrawlingParameterUtil.getUrlQueue();
                if (urlQueue != null) {
                    final String parentUrl = urlQueue.getParentUrl();
                    if (StringUtil.isNotEmpty(parentUrl)) {
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/crawler/transformer/AbstractFessFileTransformer.java

            final Map<String, String> fieldConfigMap = crawlingConfig.getConfigParameterMap(ConfigName.FIELD);
    
            String urlEncoding;
            final UrlQueue<?> urlQueue = CrawlingParameterUtil.getUrlQueue();
            if (urlQueue != null && urlQueue.getEncoding() != null) {
                urlEncoding = urlQueue.getEncoding();
            } else {
                urlEncoding = responseData.getCharSet();
            }
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/crawler/transformer/FessXpathTransformer.java

            final Map<String, String> xpathConfigMap = crawlingConfig.getConfigParameterMap(ConfigName.XPATH);
    
            String urlEncoding;
            final UrlQueue<?> urlQueue = CrawlingParameterUtil.getUrlQueue();
            if (urlQueue != null && urlQueue.getEncoding() != null) {
                urlEncoding = urlQueue.getEncoding();
            } else {
                urlEncoding = responseData.getCharSet();
            }
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 41.9K bytes
    - Viewed (0)
Back to top