- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for getUrlQueue (0.09 sec)
-
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: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 9K bytes - Viewed (0) -
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: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 2.9K bytes - Viewed (0) -
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: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 3K bytes - Viewed (0) -
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: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 3.2K bytes - Viewed (0) -
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: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 9.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/transformer/AbstractFessFileTransformer.java
final FieldConfigs fieldConfigs = new FieldConfigs(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: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 23.6K bytes - Viewed (0) -
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: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Oct 24 13:01:38 UTC 2024 - 42.9K bytes - Viewed (0)