- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 170 for getClient (0.09 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: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 23.6K 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: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 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: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 2.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: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 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: 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/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: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 4.7K 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: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Sat Oct 12 01:41:37 UTC 2024 - 15.5K 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: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 14.6K 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: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 11.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/net/InetAddressesTest.java
InetAddress server = InetAddresses.forString(serverStr); assertEquals(server, teredo.getServer()); InetAddress client = InetAddresses.forString(clientStr); assertEquals(client, teredo.getClient()); assertEquals(port, teredo.getPort()); assertEquals(flags, teredo.getFlags()); } public void testTeredoAddress_nullServer() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 24 16:44:05 UTC 2024 - 35.3K bytes - Viewed (0)