Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for OpenSearchUrlQueue (0.09 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/entity/OpenSearchUrlQueue.java

     */
    package org.codelibs.fess.crawler.entity;
    
    import java.io.IOException;
    
    import org.opensearch.core.xcontent.ToXContent;
    import org.opensearch.core.xcontent.XContentBuilder;
    
    public class OpenSearchUrlQueue extends UrlQueueImpl<String> implements ToXContent {
    
        public static final String ID = "id";
    
        public static final String SESSION_ID = "sessionId";
    
        public static final String METHOD = "method";
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

                }
            }
        }
    
        @Override
        public OpenSearchUrlQueue poll(final String sessionId) {
            final QueueHolder queueHolder = getQueueHolder(sessionId);
            final Queue<OpenSearchUrlQueue> waitingQueue = queueHolder.waitingQueue;
            final Queue<OpenSearchUrlQueue> crawlingQueue = queueHolder.crawlingQueue;
            OpenSearchUrlQueue urlQueue = waitingQueue.poll();
            if (urlQueue != null) {
    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-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java

            final OpenSearchUrlQueue urlQueue = new OpenSearchUrlQueue();
            urlQueue.setCreateTime(System.currentTimeMillis());
            urlQueue.setDepth(1);
            urlQueue.setMethod("GET");
            urlQueue.setSessionId("id1");
            urlQueue.setUrl("http://www.id1.com/");
    
            urlQueueService.insert(urlQueue);
    
            final OpenSearchUrlQueue urlQueue2 = new OpenSearchUrlQueue();
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/resources/crawler_opensearch.xml

    	<!-- Entity -->
    	<component name="accessResult"
    		class="org.codelibs.fess.crawler.entity.OpenSearchAccessResult" instance="prototype">
    	</component>
    	<component name="urlQueue"
    		class="org.codelibs.fess.crawler.entity.OpenSearchUrlQueue" instance="prototype">
    	</component>
    
    	<!-- Service -->
    	<component name="urlQueueService"
    		class="org.codelibs.fess.crawler.service.impl.OpenSearchUrlQueueService">
    		<arg>crawlerConfig</arg>
    	</component>
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 2.2K bytes
    - Viewed (0)
Back to top