- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for getClient (0.24 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute()); if (!scrollId.equals(response.getScrollId())) { getClient().clearScroll(scrollId); } scrollId = response.getScrollId(); } } finally { getClient().clearScroll(scrollId); }
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 34.3K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute()); if (!scrollId.equals(response.getScrollId())) { getClient().clearScroll(scrollId); } scrollId = response.getScrollId(); } } finally { getClient().clearScroll(scrollId); } }
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 16.9K bytes - Viewed (1) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/CrawlerClientFactoryTest.java
client = clientFactory.getClient(url); assertNotNull(client); assertTrue(client instanceof FileSystemClient); url = "smb:/home/hoge"; client = clientFactory.getClient(url); assertNotNull(client); assertTrue(client instanceof SmbClient); url = "smb1:/home/hoge"; client = clientFactory.getClient(url); assertNotNull(client);Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sat Mar 15 06:52:00 UTC 2025 - 5.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactoryWrapper.java
* @param url The URL to match. * @return The matching CrawlerClient instance. */ @Override public CrawlerClient getClient(final String url) { return factory.getClient(url); } /** * Sets the client map for the wrapped factory. * @param clientMap The map of clients. */ @OverrideRegistered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 5.2K bytes - Viewed (10) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java
response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute()); if (!scrollId.equals(response.getScrollId())) { getClient().clearScroll(scrollId); } scrollId = response.getScrollId(); } } finally { getClient().clearScroll(scrollId); } }
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 11.1K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerThreadTest.java
verify(urlQueueService, times(0)).offerAll(anyString(), any()); } /** * Test getClient method. */ public void test_getClient() throws Exception { final CrawlerClient client = mock(CrawlerClient.class); when(clientFactory.getClient("http://example.com/")).thenReturn(client); // Use reflection to access protected methodRegistered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 18.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactory.java
* Retrieves a client that matches the given URL key. * @param urlKey The URL key to match. * @return The matching CrawlerClient instance, or null if no match is found. */ public CrawlerClient getClient(final String urlKey) { if (StringUtil.isBlank(urlKey)) { return null; } for (final Map.Entry<Pattern, CrawlerClient> entry : clientMap.entrySet()) {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 7.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
/** * Gets the appropriate crawler client for the given URL. * @param url The URL to get a client for. * @return The crawler client. */ protected CrawlerClient getClient(final String url) { return clientFactory.getClient(url); } /** * Checks if the content has been updated since the last crawl. * @param client The crawler client. * @param urlQueue The URL queue entry.Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 20.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java
} return null; }) .filter(StringUtil::isNotBlank) .findFirst()// .map(s -> clientFactory.getClient(s + ":" + url))// .orElseGet(() -> clientFactory.getClient(url)); if (logger.isDebugEnabled()) { logger.debug("CrawlerClient: class={}", client.getClass().getCanonicalName()); } return client; }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Dec 11 09:47:03 UTC 2025 - 19.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/BaseThumbnailGenerator.java
config.initializeClientFactory(() -> ComponentUtil.getComponent(CrawlerClientFactory.class)); final CrawlerClient client = crawlerClientFactory.getClient(url); if (client == null) { throw new ThumbnailGenerationException("No CrawlerClient: " + configId + ", url: " + url); } String u = url;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 13.4K bytes - Viewed (0)