Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for stopFn (0.05 sec)

  1. fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                });
    
                dataService.delete(sessionId1);
                dataService.delete(sessionId2);
            } finally {
                try {
                    server1.stop();
                } finally {
                    server2.stop();
                }
            }
        }
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java

            try {
                final ResponseData responseData = httpClient.doGet(url);
                assertEquals(200, responseData.getHttpStatusCode());
            } finally {
                server.stop();
            }
        }
    
        public void test_parseLastModified() {
            final String value = "Mon, 01 Jun 2009 21:02:45 GMT";
            final Date date = httpClient.parseLastModifiedDate(value);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/JodExtractor.java

         *
         * @throws CrawlerSystemException if the office manager fails to stop
         */
        @PreDestroy
        public void destroy() {
            try {
                officeManager.stop();
            } catch (final OfficeException e) {
                throw new CrawlerSystemException("Failed to stop officeManager.", e);
            }
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  4. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/ftp/FtpClientTest.java

                assertEquals("ftp://localhost:10021/text2.txt", urlList.get(4));
            } finally {
                if (server != null) {
                    server.stop();
                }
            }
        }
    
        public void test_doGet_dir1() throws FtpException {
            FtpServer server = null;
            try {
                String username = "testuser";
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 18K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

            if (StringUtil.isNotBlank(regexp)) {
                urlFilter.addExclude(regexp);
            }
        }
    
        /**
         * Stops the crawling process.
         * Sets the crawler status to DONE and interrupts all crawler threads.
         */
        public void stop() {
            crawlerContext.setStatus(CrawlerStatus.DONE);
            try {
                if (crawlerThreadGroup != null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                });
    
                dataService.delete(sessionId1);
                dataService.delete(sessionId2);
            } finally {
                try {
                    server1.stop();
                } finally {
                    server2.stop();
                }
            }
        }
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  7. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java

                    SetObjectTagsArgs.builder().bucket(bucketName).object("dir3/file4.txt").tags(Map.of("label", "label4")).build());
        }
    
        @Override
        protected void tearDown() throws Exception {
            minioServer.stop();
            super.tearDown();
        }
    
        public void test_doGet() throws Exception {
            try (final ResponseData responseData = storageClient.doGet("storage://fess/file1.txt")) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 13.8K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (accessTimeoutTask != null && !accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Sep 18 09:30:45 UTC 2025
    - 23K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractor.java

                }
            } catch (final IOException e) {
                throw new ExtractException(e);
            } finally {
                if (accessTimeout != null) {
                    accessTimeoutTarget.stop();
                    if (!accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
            return data;
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (!accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 13.8K bytes
    - Viewed (0)
Back to top