- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for deleteBySessionId (0.27 sec)
-
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) -
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) -
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) -
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) -
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) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 23.6K bytes - Viewed (0) -
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)