- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for offerAll (0.41 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java
*/ void deleteAll(); /** * Offers all URL queues. * * @param sessionId The session ID. * @param newUrlQueueList The list of new URL queues. */ void offerAll(String sessionId, List<QUEUE> newUrlQueueList); /** * Polls a URL queue. * * @param sessionId The session ID. * @return The URL queue. */ QUEUE poll(String sessionId);Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 2.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java
dataHelper.clearUrlQueueList(); } /* * (non-Javadoc) * * @see org.codelibs.fess.crawler.service.UrlQueueService#offerAll(java.lang.String, * java.util.List) */ @Override public void offerAll(final String sessionId, final List<UrlQueueImpl<Long>> newUrlQueueList) { final Queue<UrlQueueImpl<Long>> urlQueueList = dataHelper.getUrlQueueList(sessionId);
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 9.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java
crawlerContext.decrementAndGetAccessCount(); final List<UrlQueue<?>> newUrlQueueList = new ArrayList<>(); newUrlQueueList.add(urlQueue); urlQueueService.offerAll(crawlerContext.getSessionId(), newUrlQueueList); } } else if (logger.isDebugEnabled()) { logger.debug("Visited urlQueue: {}", urlQueue); } } /**
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 12.5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 20.4K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
* Only URLs that don't already exist will be added. * * @param sessionId The session ID. * @param urlQueueList The list of URL queue entries to offer. */ @Override public void offerAll(final String sessionId, final List<OpenSearchUrlQueue> urlQueueList) { if (logger.isDebugEnabled()) { logger.debug("Offering URL: Session ID: {}, UrlQueue: {}", sessionId, urlQueueList); }
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 17K bytes - Viewed (1)