assertNull(polled);
    }

    @Test
    public void test_offerAll_duplicateUrlsTx() {
        final String sessionId = "offer_session2";
        final List<OpenSearchUrlQueue> urlQueueList = new ArrayList<>();

        final OpenSearchUrlQueue urlQueue1 = new OpenSearchUrlQueue();
        urlQueue1.setCreateTime(System.currentTimeMillis());