Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for getClient (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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 method
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 40K bytes
    - Viewed (0)
  9. 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: " + url + ". Unable to access the document without a crawler client.");
            }
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  10. 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: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 52.6K bytes
    - Viewed (0)
Back to top