Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for updateSessionId (0.09 sec)

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

        protected MemoryDataHelper dataHelper;
    
        /*
         * (non-Javadoc)
         *
         * @see
         * org.codelibs.fess.crawler.service.UrlQueueService#updateSessionId(java.lang.String
         * , java.lang.String)
         */
        @Override
        public void updateSessionId(final String oldSessionId, final String newSessionId) {
            // not MT-safe
            final Queue<UrlQueueImpl<Long>> urlQueueList = dataHelper.getUrlQueueList(oldSessionId);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java

    import java.util.List;
    
    import org.codelibs.fess.crawler.entity.UrlQueue;
    
    /**
     * @author shinsuke
     *
     */
    public interface UrlQueueService<QUEUE extends UrlQueue<?>> {
    
        void updateSessionId(String oldSessionId, String newSessionId);
    
        void add(String sessionId, String url);
    
        void insert(QUEUE urlQueue);
    
        void delete(String sessionId);
    
        void deleteAll();
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

        }
    
        public void setSessionId(final String sessionId) {
            if (StringUtil.isNotBlank(sessionId) && !sessionId.equals(crawlerContext.sessionId)) {
                urlQueueService.updateSessionId(crawlerContext.sessionId, sessionId);
                crawlerContext.sessionId = sessionId;
            }
        }
    
        public String execute() {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

                    logger.warn("Failed to restore " + urlQueue, e);
                }
            }));
        }
    
        public void clearCache() {
            sessionCache.clear();
        }
    
        @Override
        public void updateSessionId(final String oldSessionId, final String newSessionId) {
            SearchResponse response = getClient().get(c -> c.prepareSearch(index).setScroll(new TimeValue(scrollTimeout))
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
Back to top