// Create a mock UrlQueueService
        UrlQueueService<UrlQueue<?>> service = new UrlQueueService<UrlQueue<?>>() {
            @Override
            public void updateSessionId(String oldSessionId, String newSessionId) {
            }

            @Override
            public void add(String sessionId, String url) {
            }

            @Override

        if (StringUtil.isNotBlank(sessionId) && !sessionId.equals(crawlerContext.sessionId)) {
            final String oldSessionId = crawlerContext.sessionId;
            urlQueueService.updateSessionId(crawlerContext.sessionId, sessionId);
            crawlerContext.sessionId = sessionId;
            if (logger.isInfoEnabled()) {

        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);

    /**
     * Updates the session ID for all URL queue entries.
     *
     * @param oldSessionId The old session ID.
     * @param newSessionId The new session ID.
     */
    @Override
    public void updateSessionId(final String oldSessionId, final String newSessionId) {
        SearchResponse response = getClient().get(c -> c.prepareSearch(index)
                .setScroll(new TimeValue(scrollTimeout))