@Test
    public void testBenchCompleteRecycledPublisher() throws IOException {
        CompleteRecycledPublisher publisher;
        publisher = new CompleteRecycledPublisher();
        publisher.setQueueName("BENCH");
        publisher.prepare();
        for (long ii = 0; ii < 1000000000L; ii++) {
            publisher.run();
        }

        publisher.drop();
    }