- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for getClients (0.49 sec)
-
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsUrlQueueService.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: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 12.9K 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: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 11.1K bytes - Viewed (0) -
android/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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 24 16:44:05 UTC 2024 - 35.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ViewHelper.java
final CrawlerClientFactory crawlerClientFactory = config.initializeClientFactory(() -> ComponentUtil.getComponent(CrawlerClientFactory.class)); final CrawlerClient client = crawlerClientFactory.getClient(url); if (client == null) { throw new FessSystemException("No CrawlerClient: " + configId + ", url: " + url); } return writeContent(configId, url, client); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu May 30 06:58:45 UTC 2024 - 40.2K 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: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 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: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 14.6K 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); responseData.setUrl(ftpInfo.toUrl()); client = getClient(ftpInfo); FTPFile file = null; client.changeWorkingDirectory(ftpInfo.getParent()); validateRequest(client); if (ftpInfo.getName() == null) {
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 25.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/DocumentHelper.java
} final CrawlerClientFactory crawlerClientFactory = crawlingConfig.initializeClientFactory(ComponentUtil::getCrawlerClientFactory); final CrawlerClient client = crawlerClientFactory.getClient(url); if (client == null) { throw new CrawlingAccessException("CrawlerClient is null for " + url); } final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 12K bytes - Viewed (0) -
src/main/java/jcifs/smb/Kerb5Context.java
for ( KerberosTicket ticket : subject.getPrivateCredentials(KerberosTicket.class) ) { MIEName client = new MIEName(mech, ticket.getClient().getName()); MIEName server = new MIEName(mech, ticket.getServer().getName()); if ( src.equals(client) && targ.equals(server) ) { return ticket.getSessionKey(); }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu Aug 02 08:22:42 UTC 2018 - 13.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
return; } final String url = dataMap.get(fessConfig.getIndexFieldUrl()).toString(); final CrawlerClient client = crawlerClientFactory.getClient(url); if (client == null) { logger.warn("CrawlerClient is null. Data: {}", dataMap); return; }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.8K bytes - Viewed (0)