Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for awaitable (0.05 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/log/LogType.java

        CRAWLING_EXCEPTION,
        /** Indicates no URL is available in the queue. */
        NO_URL_IN_QUEUE,
        /** Indicates the start of a crawler thread. */
        START_THREAD,
        /** Indicates the finish of a crawler thread. */
        FINISHED_THREAD,
        /** Indicates no response processor is available. */
        NO_RESPONSE_PROCESSOR,
        /** Indicates no rule is available for processing. */
        NO_RULE,
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  2. fess-crawler-lasta/src/main/java/org/codelibs/fess/crawler/container/LastaCrawlerContainer.java

        }
    
        @Override
        public <T> T getComponent(final String name) {
            return SingletonLaContainerFactory.getContainer().getComponent(name);
        }
    
        @Override
        public boolean available() {
            return SingletonLaContainerFactory.hasContainer();
        }
    
        @Override
        public void destroy() {
            SingletonLaContainerFactory.destroy();
        }
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  3. fess-crawler/src/test/java/org/codelibs/fess/crawler/exception/CrawlerSystemExceptionTest.java

            // Test with suppression enabled and writable stack trace
            String message1 = "Test with suppression enabled";
            CrawlerSystemException exception1 = constructor.newInstance(message1, true, true);
            assertNotNull(exception1);
            assertEquals(message1, exception1.getMessage());
            assertNull(exception1.getCause());
    
            // Test with suppression disabled and writable stack trace
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 20K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStream.java

        /**
         * Returns the number of bytes that can be read from this input stream without blocking.
         *
         * @return the number of bytes available
         * @throws IOException if an I/O error occurs
         */
        @Override
        public int available() throws IOException {
            return inputStream.available();
        }
    
        /**
         * Indicates whether some other object is equal to this one.
         *
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/exception/CrawlerSystemException.java

     * It also provides a protected constructor that allows to specify whether or not suppression is enabled or stack trace is writable.
     */
    public class CrawlerSystemException extends RuntimeException {
    
        private static final long serialVersionUID = 1L;
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 3K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/container/CrawlerContainer.java

         * @return the component instance of the specified type
         */
        <T> T getComponent(String name);
    
        /**
         * Checks if the crawler container is available.
         *
         * @return true if the crawler container is available, false otherwise.
         */
        boolean available();
    
        /**
         * Cleans up resources and performs any necessary finalization tasks
         * before the object is destroyed. This method should be called to
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java

         * @see java.io.InputStream#read()
         */
        @Override
        public int read() throws IOException {
            return fileInputStream.read();
        }
    
        @Override
        public int available() throws IOException {
            return fileInputStream.available();
        }
    
        /**
         * Closes this input stream and releases any system resources associated with the stream.
         * @throws IOException if an I/O error occurs.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/exception/ExtractException.java

         * suppression enabled or disabled, and writable stack trace enabled or disabled.
         *
         * @param message the detail message.
         * @param enableSuppression whether or not suppression is enabled or disabled.
         * @param writableStackTrace whether or not the stack trace should be writable.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 3K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientCreator.java

            } catch (final Exception e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to create {}.", componentName, e);
                } else {
                    logger.info("{} is not available.", componentName);
                }
            }
        }
    
        /**
         * Sets the maximum client factory size.
         * @param maxClientFactorySize The maximum size.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/storage/Handler.java

             * @throws InsufficientDataException If insufficient data is available
             * @throws InternalException If an internal error occurs
             * @throws InvalidResponseException If the response is invalid
             * @throws NoSuchAlgorithmException If the algorithm is not available
             * @throws XmlParserException If XML parsing fails
             * @throws IOException If an I/O error occurs
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 10.5K bytes
    - Viewed (0)
Back to top