- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for actionGet (0.12 sec)
-
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java
.execute().actionGet().getHits().getTotalHits().value > 0); urlQueueService.delete("sessionId"); assertFalse(fesenClient.prepareSearch("fess_crawler.queue").setQuery(QueryBuilders.termQuery("sessionId", "sessionId")).setSize(0) .execute().actionGet().getHits().getTotalHits().value > 0); }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 5.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
.actionGet(fessConfig.getIndexIndicesTimeout()); final GetIndexResponse response = client.admin().indices().prepareGetIndex().addIndices(fessConfig.getIndexDocumentUpdateIndex()).execute() .actionGet(fessConfig.getIndexIndicesTimeout());
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sun Oct 20 02:08:03 UTC 2024 - 86.1K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
} public <T> T get(final Function<FesenClient, ActionFuture<T>> func) { int retryCount = 0; while (true) { try { return func.apply(this).actionGet(connTimeout, TimeUnit.MILLISECONDS); } catch (final IndexNotFoundException | VersionConflictEngineException e) { logger.debug("{} occurs.", e.getClass().getName(), e); throw e;
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 19.9K bytes - Viewed (0)