@Test
    public void testBenchCompleteRecycledConsumer() throws IOException {

        GeneralConsumer consumer;
        consumer = new GeneralConsumer();
        consumer.setAutoAck(false);
        consumer.setQueueName("BENCH");
        consumer.prepare();
        for (long ii = 0; ii < 100000000L; ii++) {
            consumer.run();
        }

    }