assertTrue(polled.getUrl().startsWith("http://www.example.com/page"));
        }

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

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