Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for getClient (0.06 sec)

  1. 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 Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (0)
  2. 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 Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  3. 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 Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  4. 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.
         */
        @Override
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  5. 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 Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  6. 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: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 7K bytes
    - Viewed (0)
  7. 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.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  8. 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: {}", client.getClass().getCanonicalName());
            }
            return client;
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  9. 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 Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  10. guava/src/com/google/common/net/InetAddresses.java

          this.port = port;
          this.flags = flags;
        }
    
        public Inet4Address getServer() {
          return server;
        }
    
        public Inet4Address getClient() {
          return client;
        }
    
        public int getPort() {
          return port;
        }
    
        public int getFlags() {
          return flags;
        }
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 47.4K bytes
    - Viewed (0)
Back to top