Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for processor (0.21 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/RuleTest.java

            }
        }
    
        /**
         * Test rule processor chain behavior
         */
        public void test_ruleProcessorChain() {
            final List<String> executionOrder = new ArrayList<>();
    
            // Create custom processor that tracks execution
            ResponseProcessor processor = new ResponseProcessor() {
                @Override
                public void process(ResponseData responseData) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 22.7K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/impl/AbstractRuleTest.java

            // Initial state
            assertNull(testRule.getResponseProcessor());
    
            // Set response processor
            TestResponseProcessor processor = new TestResponseProcessor();
            testRule.setResponseProcessor(processor);
            assertSame(processor, testRule.getResponseProcessor());
    
            // Change response processor
            TestResponseProcessor newProcessor = new TestResponseProcessor();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/impl/LogHelperImpl.java

                logger.debug("No rule for ({}, {}). PLEASE CHECK YOUR CONFIGURATION.", responseData.getUrl(), responseData.getMimeType());
            }
        }
    
        /**
         * Processes no response processor found log events.
         *
         * @param objs the log objects (should contain ResponseData)
         */
        protected void processNoResponseProcessor(final Object... objs) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java

         */
        public DefaultResponseProcessor() {
            // Default constructor
        }
    
        /**
         * Processes response data based on HTTP status code and configured transformer.
         *
         * @param responseData the response data to process
         */
        @Override
        public void process(final ResponseData responseData) {
            if (isNotModified(responseData)) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                    .<DefaultResponseProcessor> singleton("defaultResponseProcessor", DefaultResponseProcessor.class, processor -> {
                        processor.setTransformer(container.getComponent("fileTransformer"));
                        processor.setSuccessfulHttpCodes(new int[] { 200 });
                        processor.setNotModifiedHttpCodes(new int[] { 304 });
                    })//
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

                    }
                }
            }
            return true;
        }
    
        /**
         * Processes the response data using the appropriate rule processor.
         * @param urlQueue The URL queue entry.
         * @param responseData The response data to process.
         */
        protected void processResponse(final UrlQueue<?> urlQueue, final ResponseData responseData) {
            // get a rule
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  7. fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/RuleManagerTest.java

    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.codelibs.fess.crawler.entity.ResponseData;
    import org.codelibs.fess.crawler.processor.ResponseProcessor;
    import org.dbflute.utflute.core.PlainTestCase;
    
    /**
     * Test class for RuleManager interface.
     * Tests the contract and behavior of RuleManager implementations.
     */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 23.8K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TextUtil.java

                this.reader = reader;
            }
    
            /**
             * Executes the text processing operation on the provided reader.
             *
             * This method reads characters from the reader and processes them according to the following rules:
             * - ISO control characters and space characters are treated as spaces.
             * - Alphanumeric characters (0-9, A-Z, a-z) are appended to the buffer.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 12K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java

             * Constructs a new MonitorThread.
             * @param process The process to monitor.
             * @param timeout The timeout for the process.
             */
            public MonitorThread(final Process process, final long timeout) {
                this.process = process;
                this.timeout = timeout;
            }
    
            @Override
            public void run() {
                ThreadUtil.sleepQuietly(timeout);
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 16K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

            }
        }
    
        /**
         * Processes allowed SIDs (Security Identifiers) and adds them to the SID set.
         * If the SID is a group, it recursively processes all group members.
         *
         * @param file the SMB1 file
         * @param sid the SID to process
         * @param sidSet the set of SIDs to add to
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Sep 18 09:30:45 UTC 2025
    - 23K bytes
    - Viewed (0)
Back to top