public SharedConnectionPublisherBench() {
        try {
            final ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("127.0.0.1");
            connection = factory.newConnection();

        } catch (IOException ex) {
            Logger.getLogger(SharedConnectionBench.class.getName()).log(Level.SEVERE, null, ex);
        }
    }