@Test
    public void testBenchSharedConnectionPublisher() throws IOException {
        final SharedConnectionPublisher publisher
                = new SharedConnectionPublisher(connection);
        publisher.setQueueName("BENCH_SHARED");
        publisher.prepare();

        for (long ii = 0; ii < 1000000000L; ii++) {
            publisher.run();
        }

        publisher.drop();
    }