Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getUrlQueueList (0.25 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImplTest.java

            Queue<UrlQueueImpl<Long>> mockQueue = new LinkedList<>();
    
            when(dataHelper.getUrlQueueList(oldSessionId)).thenReturn(mockQueue);
    
            // Execute
            service.updateSessionId(oldSessionId, newSessionId);
    
            // Verify
            verify(dataHelper).getUrlQueueList(oldSessionId);
            verify(dataHelper).addUrlQueueList(newSessionId, mockQueue);
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 13 13:29:22 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java

         */
        @Override
        public void updateSessionId(final String oldSessionId, final String newSessionId) {
            // not MT-safe
            final Queue<UrlQueueImpl<Long>> urlQueueList = dataHelper.getUrlQueueList(oldSessionId);
            // overwrite
            dataHelper.addUrlQueueList(newSessionId, urlQueueList);
            dataHelper.removeUrlQueueList(oldSessionId);
        }
    
        /*
         * (non-Javadoc)
         *
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MemoryDataHelper.java

         * Creates a new queue if one doesn't exist.
         * @param sessionId the session ID
         * @return the URL queue for the session
         */
        public synchronized Queue<UrlQueueImpl<Long>> getUrlQueueList(final String sessionId) {
            Queue<UrlQueueImpl<Long>> urlQueueList = urlQueueMap.get(sessionId);
            if (urlQueueList == null) {
                urlQueueList = new LinkedList<>();
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 8.1K bytes
    - Viewed (0)
Back to top