- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 93 for getClient (0.04 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: 2025-05-25 03:50 - Last Modified: 2025-05-18 03:08 - 23.7K 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: 2025-05-25 03:50 - Last Modified: 2025-03-15 06:52 - 13.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactoryWrapper.java
@Override public void addClient(final List<String> regexList, final CrawlerClient client) { factory.addClient(regexList, client); } @Override public CrawlerClient getClient(final String url) { return factory.getClient(url); } @Override public void setClientMap(final Map<Pattern, CrawlerClient> clientMap) { factory.setClientMap(clientMap); } @Override
Registered: 2025-05-25 03:50 - Last Modified: 2025-03-15 06:52 - 3.4K bytes - Viewed (0) -
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: 2025-05-25 03:50 - Last Modified: 2025-03-15 06:52 - 5.3K bytes - Viewed (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); } }
Registered: 2025-05-25 03:50 - Last Modified: 2025-05-18 03:08 - 8.5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactory.java
if (StringUtil.isNotBlank(regex)) { clientMap.put(Pattern.compile(regex), client); } } } public CrawlerClient getClient(final String urlKey) { if (StringUtil.isBlank(urlKey)) { return null; } for (final Map.Entry<Pattern, CrawlerClient> entry : clientMap.entrySet()) {
Registered: 2025-05-25 03:50 - Last Modified: 2025-04-13 01:41 - 5.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java
return e.getFirst(); } return null; }).filter(StringUtil::isNotBlank).findFirst()// .map(s -> clientFactory.getClient(s + ":" + url))// .orElseGet(() -> clientFactory.getClient(url)); if (logger.isDebugEnabled()) { logger.debug("CrawlerClient: {}", client.getClass().getCanonicalName()); } return client; }
Registered: 2025-05-26 08:04 - Last Modified: 2025-03-15 06:53 - 14.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
} } } } protected CrawlerClient getClient(final String url) { return clientFactory.getClient(url); } protected boolean isContentUpdated(final CrawlerClient client, final UrlQueue<?> urlQueue) { if (urlQueue.getLastModified() != null) {
Registered: 2025-05-25 03:50 - Last Modified: 2025-03-15 06:52 - 17.2K 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: 2025-05-26 08:04 - Last Modified: 2025-03-15 06:53 - 11.1K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java
try { responseData.setMethod(Constants.GET_METHOD); final FtpInfo ftpInfo = new FtpInfo(uri, charset); responseData.setUrl(ftpInfo.toUrl()); client = getClient(ftpInfo); FTPFile file = null; client.changeWorkingDirectory(ftpInfo.getParent()); validateRequest(client); if (ftpInfo.getName() == null) {
Registered: 2025-05-25 03:50 - Last Modified: 2025-05-24 06:10 - 30.1K bytes - Viewed (0)