.execute()
                .actionGet()
                .getHits()
                .getTotalHits()
                .value() > 0);
    }

    @Test
    public void test_poll_emptyQueueTx() {
        final String sessionId = "poll_session1";

        // Poll from empty queue should return null
        final OpenSearchUrlQueue result = urlQueueService.poll(sessionId);
        assertNull(result);