Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for deleteBySessionId (0.27 sec)

  1. src/main/java/org/codelibs/fess/helper/IndexingHelper.java

            }
            return 0;
        }
    
        public long deleteBySessionId(final String sessionId) {
            final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient();
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final String index = fessConfig.getIndexDocumentUpdateIndex();
            return deleteBySessionId(searchEngineClient, index, sessionId);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java

            }
            insertAll(urlFilterList, OpType.INDEX);
            invalidateSet.forEach(s -> excludeFilterCache.invalidate(s));
        }
    
        @Override
        public void delete(final String sessionId) {
            deleteBySessionId(sessionId);
            includeFilterCache.invalidate(sessionId);
            excludeFilterCache.invalidate(sessionId);
        }
    
        @Override
        public List<Pattern> getIncludeUrlPatternList(final String sessionId) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  3. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java

            return getCount(builder -> builder.setQuery(QueryBuilders.termQuery(SESSION_ID, sessionId)));
        }
    
        @Override
        public void delete(final String sessionId) {
            deleteBySessionId(sessionId);
        }
    
        @Override
        public OpenSearchAccessResult getAccessResult(final String sessionId, final String url) {
            return get(OpenSearchAccessResult.class, sessionId, url);
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

                    }
                    return;
                }
                throw e;
            }
        }
    
        @Override
        public void delete(final String sessionId) {
            deleteBySessionId(sessionId);
        }
    
        @Override
        public void offerAll(final String sessionId, final List<OpenSearchUrlQueue> urlQueueList) {
            if (logger.isDebugEnabled()) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

        }
    
        public void addFinishedSessionId(final String sessionId) {
            synchronized (finishedSessionIdList) {
                finishedSessionIdList.add(sessionId);
            }
        }
    
        private void deleteBySessionId(final String sessionId) {
            try {
                urlFilterService.delete(sessionId);
            } catch (final Exception e) {
                logger.warn("Failed to delete url filters: {}", sessionId, e);
            }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  6. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

            } catch (final Exception e) {
                throw new OpenSearchAccessException("Failed to delete " + sessionId + ":" + url, e);
            }
        }
    
        protected void deleteBySessionId(final String sessionId) {
            delete(builder -> builder.setQuery(QueryBuilders.termQuery(SESSION_ID, sessionId)));
        }
    
        public void deleteAll() {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/helper/IndexingHelperTest.java

                    return 0;
                }
            };
            ComponentUtil.register(client, "searchEngineClient");
    
            final String sessionId = "session1";
    
            assertEquals(1, indexingHelper.deleteBySessionId(sessionId));
            assertEquals("fess.update", resultMap.get("index"));
            assertEquals("segment", resultMap.get("field"));
            assertEquals(sessionId, resultMap.get("value"));
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Wed Jul 24 08:54:24 UTC 2024
    - 23.4K bytes
    - Viewed (0)
Back to top