try (RankFusionProcessor processor = new RankFusionProcessor()) {
            processor.setSearcher(new TestSearcher(100));
            processor.register(new NullDocumentSearcher());
            processor.init();

            // Should handle null documents gracefully
            final List<Map<String, Object>> results = processor.search("*", new TestSearchRequestParams(0, 10, 0), OptionalThing.empty());

        def testError2 = Mock(Throwable)

        when:
        processor.started(rootDescriptor, rootTestStartEvent)
        processor.started(testDescriptor1, testStartEvent1)
        processor.started(testDescriptor2, testStartEvent2)
        processor.failure("testId2", testError2)
        processor.completed("rootId", rootCompleteEvent)

        then:

        final CountDownLatch endLatch = new CountDownLatch(numThreads);
        final AtomicInteger registeredCount = new AtomicInteger(0);

        try (RankFusionProcessor processor = new RankFusionProcessor()) {
            processor.setSearcher(new TestSearcher(100));
            processor.init();

            final ExecutorService executor = Executors.newFixedThreadPool(numThreads);
            try {
                for (int i = 0; i < numThreads; i++) {

            processor = ProcessorHolder.CACHED_PROCESSOR.get();
        }
        return processor.process(object);
    }

    /**
     * Load the first available processor implementation.
     */
    private static ModelObjectProcessor loadProcessor() {
        /*
         * No-op processor that returns objects unchanged.
         */
        class NoOpProcessor implements ModelObjectProcessor {

            this.modularJar = requireType(Type.MODULAR_JAR);
            this.processor = requireType(Type.PROCESSOR);
            this.classpathProcessor = requireType(Type.CLASSPATH_PROCESSOR);
            this.modularProcessor = requireType(Type.MODULAR_PROCESSOR);
            this.needsDerive = Set.of(Type.PROCESSOR, Type.CLASSPATH_PROCESSOR, Type.MODULAR_PROCESSOR);
            this.stack = new ArrayDeque<>();
        }

 */
package org.codelibs.fess.crawler.processor;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.codelibs.fess.crawler.entity.AccessResult;
import org.codelibs.fess.crawler.entity.ResponseData;
import org.codelibs.fess.crawler.entity.ResultData;
import org.codelibs.fess.crawler.processor.impl.DefaultResponseProcessor;
import org.codelibs.fess.ingest.IngestFactory;

	<component name="sitemapsRule" class="org.codelibs.fess.crawler.rule.impl.SitemapsRule" >
		<property name="ruleId">"sitemapsRule"</property>
		<property name="responseProcessor">
			<component class="org.codelibs.fess.crawler.processor.impl.SitemapsResponseProcessor">
			</component>
		</property>
		<postConstruct name="addRule">
			<arg>"url"</arg>
			<arg>"http[s]?:.*sitemap[^/]*\.xml.*|http[s]?:.*sitemap[^/]*\.gz.*|http[s]?:.*sitemap[^/]*\.txt.*"</arg>

    /**
     * Artifact type name for a JAR file that can be placed either on the annotation processor class path
     * or module path. The path (classes or modules) is chosen by the plugin, possibly using heuristic rules.
     */
    String PROCESSOR = "processor";

    /**
     * Artifact type name for a JAR file to unconditionally place on the annotation processor class path.
     * If the JAR is modular, its module information are ignored.
     */

                    java.util.function.BiFunction<org.opensearch.action.update.UpdateRequestBuilder, org.opensearch.search.SearchHit, org.opensearch.action.update.UpdateRequestBuilder> processor) {
                // Return a fixed count for testing
                return 3L;
            }
        };
        ComponentUtil.register(mockSearchEngineClient, "searchEngineClient");

        // Mock FessConfig

    static final Set<String> PROCESSOR_TYPE_IDS =
            Set.of(Type.PROCESSOR, Type.CLASSPATH_PROCESSOR, Type.MODULAR_PROCESSOR);

    private static final Map<String, String> DERIVE_MAP = Map.of(
            Type.JAR, Type.PROCESSOR,
            Type.CLASSPATH_JAR, Type.CLASSPATH_PROCESSOR,
            Type.MODULAR_JAR, Type.MODULAR_PROCESSOR);

    @Override