}

        assertEquals(5, count);
        urlQueueService.delete(sessionId);
    }

    @Test
    public void test_poll_concurrentAccessTx() throws Exception {
        final String sessionId = "poll_session4";
        final int numThreads = 5;
        final int itemsPerThread = 10;