- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 15 for getClients (0.06 seconds)
-
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); }
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Nov 20 08:40:57 GMT 2025 - 34.3K bytes - Click Count (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); } }
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Nov 20 08:40:57 GMT 2025 - 16.9K bytes - Click Count (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);Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sat Mar 15 06:52:00 GMT 2025 - 5.3K bytes - Click Count (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. */ @OverrideCreated: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sun Jul 06 02:13:03 GMT 2025 - 5.2K bytes - Click Count (10) -
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 methodCreated: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 18.3K bytes - Click Count (0) -
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); } }
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 11.1K bytes - Click Count (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()) {Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 7.3K bytes - Click Count (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.Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Aug 07 02:55:08 GMT 2025 - 20.4K bytes - Click Count (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; }Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Dec 11 09:47:03 GMT 2025 - 19.5K bytes - Click Count (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;
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 13.4K bytes - Click Count (0)