Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for getClients (0.15 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: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K 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: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (0)
  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: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 13.5K bytes
    - Viewed (1)
  8. 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: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 17.2K bytes
    - Viewed (0)
  9. 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: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 52.4K bytes
    - Viewed (0)
  10. 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: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 28.9K bytes
    - Viewed (0)
Back to top