Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 57 for get_client (0.06 seconds)

  1. 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.
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Dec 31 09:07:38 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  2. 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;
        }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Dec 11 09:47:03 GMT 2025
    - 19.5K bytes
    - Click Count (0)
  3. 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()) {
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Mon Nov 24 03:59:47 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/general/AdminGeneralAction.java

            return llmClientManager.getClients().length > 0;
        }
    
        private List<Map<String, String>> getRagLlmNameItems() {
            final List<Map<String, String>> itemList = new ArrayList<>();
            final LlmClientManager llmClientManager = ComponentUtil.getComponent("llmClientManager");
            for (final LlmClient client : llmClientManager.getClients()) {
                final Map<String, String> map = new HashMap<>();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 05:54:31 GMT 2026
    - 27.2K bytes
    - Click Count (0)
  5. 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;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/net/InetAddressesTest.java

        InetAddress server = InetAddresses.forString(serverStr);
        assertThat(teredo.getServer()).isEqualTo(server);
    
        InetAddress client = InetAddresses.forString(clientStr);
        assertThat(teredo.getClient()).isEqualTo(client);
    
        assertEquals(port, teredo.getPort());
        assertEquals(flags, teredo.getFlags());
      }
    
      public void testTeredoAddress_nullServer() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 16:38:16 GMT 2026
    - 36.3K bytes
    - Click Count (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();
                }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 13.5K bytes
    - Click Count (1)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt

      private var port = 0
      private val executor = Executors.newSingleThreadExecutor(threadFactory("MockHttp2Peer"))
      private var serverSocket: ServerSocket? = null
      private var socket: Socket? = null
    
      fun setClient(client: Boolean) {
        if (this.client == client) return
        this.client = client
        writer = Http2Writer(bytesOut, client)
      }
    
      fun acceptFrame() {
        frameCount++
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  9. 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) {
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Mon Nov 24 03:59:47 GMT 2025
    - 40K bytes
    - Click Count (0)
  10. 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.");
            }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Mar 30 14:27:04 GMT 2026
    - 17.4K bytes
    - Click Count (0)
Back to Top