// Default weight should be 1.0
        assertEquals(1.0f, queue.getWeight(), 0.001f);

        queue.setWeight(0.5f);
        assertEquals(0.5f, queue.getWeight(), 0.001f);

        queue.setWeight(2.5f);
        assertEquals(2.5f, queue.getWeight(), 0.001f);

        queue.setWeight(0.0f);
        assertEquals(0.0f, queue.getWeight(), 0.001f);
    }

    public void test_toString() {

        // Default weight should be 1.0
        assertEquals(1.0f, data.getWeight(), 0.001f);

        data.setWeight(0.5f);
        assertEquals(0.5f, data.getWeight(), 0.001f);

        data.setWeight(2.5f);
        assertEquals(2.5f, data.getWeight(), 0.001f);

        data.setWeight(0.0f);
        assertEquals(0.0f, data.getWeight(), 0.001f);
    }

    public void test_equalsAndHashCode() {

        assertEquals(data1.getUrl(), data2.getUrl());
        assertEquals(data1.getWeight(), data2.getWeight(), 0.001f);

        assertEquals(data2.getMethod(), data3.getMethod());
        assertEquals(data2.getUrl(), data3.getUrl());
        assertEquals(data2.getWeight(), data3.getWeight(), 0.001f);
    }

    public void test_overwritingValues() {

                    uq.setParentUrl(url);
                    uq.setSessionId(crawlerContext.sessionId);
                    uq.setUrl(d.getUrl());
                    uq.setWeight(d.getWeight());
                    return uq;
                })
                .collect(Collectors.toList());
        urlQueueService.offerAll(crawlerContext.sessionId, childList);
    }

    /**

                }
                throw new ExtractException("Failed to extract the content using available extractors.");
            }

            @Override
            public int getWeight() {
                return extractors[0].getWeight();
            }
        };
    }

    /**
     * Retrieves all extractors for the specified key.
     * @param key The key associated with the extractors.

              } else if (map.isExpired(e, now)) {
                // This is a duplicate check, as preWriteCleanup already purged expired
                // entries, but let's accommodate an incorrect expiration queue.
                enqueueNotification(
                    entryKey, hash, value, valueReference.getWeight(), RemovalCause.EXPIRED);

    /**
     * Constructs a new MarkdownExtractor and initializes the parser.
     */
    public MarkdownExtractor() {
        super();
        initializeParser();
    }

    @Override
    public int getWeight() {
        return 2; // Higher priority than TikaExtractor (weight=1)
    }

    /**
     * Initializes the Markdown parser with extensions.
     */
    protected void initializeParser() {

                    uq.setParentUrl(url);
                    uq.setSessionId(crawlerContext.getSessionId());
                    uq.setUrl(d.getUrl());
                    uq.setWeight(d.getWeight());
                    return uq;
                })
                .collect(Collectors.toList());

        if (!childList.isEmpty()) {

            @Override
            public void setCreateTime(Long createTime) {
            }

            @Override
            public float getWeight() {
                return 0;
            }

            @Override
            public void setWeight(float weight) {
            }
        };
    }

    public void test_urlQueue_setAndGet() {
        // Initially should be null

        final OpenSearchUrlQueue first = urlQueueService.poll(sessionId);
        assertNotNull(first);
        // Weight should be highest
        assertTrue(first.getWeight() >= 1);

        urlQueueService.delete(sessionId);
    }

    public void test_offerAll_emptyListTx() {
        final String sessionId = "offer_session1";
        final List<OpenSearchUrlQueue> emptyList = new ArrayList<>();