Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 171 for getClient (0.06 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 Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 23.6K 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 Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactoryWrapper.java

        @Override
        public void addClient(final List<String> regexList, final CrawlerClient client) {
            factory.addClient(regexList, client);
        }
    
        @Override
        public CrawlerClient getClient(final String url) {
            return factory.getClient(url);
        }
    
        @Override
        public void setClientMap(final Map<Pattern, CrawlerClient> clientMap) {
            factory.setClientMap(clientMap);
        }
    
        @Override
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. 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 Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 5.3K 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 Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactory.java

                if (StringUtil.isNotBlank(regex)) {
                    clientMap.put(Pattern.compile(regex), client);
                }
            }
        }
    
        public CrawlerClient getClient(final String urlKey) {
            if (StringUtil.isBlank(urlKey)) {
                return null;
            }
    
            for (final Map.Entry<Pattern, CrawlerClient> entry : clientMap.entrySet()) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. 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: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:41:37 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  8. 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: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 14.6K 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 Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  10. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 24 16:44:05 UTC 2024
    - 35.3K bytes
    - Viewed (0)
Back to top