Connection.java

@Override
public void start(Future<Void> future) throws Exception {
   super.start();
   NetServerOptions options = new NetServerOptions().setLogActivity(true);
   NetServer server = vertx.createNetServer(options);

   server.connectHandler(socket -> onInput(configuration, socket))
         .listen(configuration.getPort(), configuration.getHost(), connectionStartedHandler(future, configuration));
}

...

private void onInput(Connection configuration, NetSocket socket) {
   socket.handler(buffer -> {
       String message = buffer.getString(0, buffer.length());
       logger.info("Got input: " + message);
       EventBus eventBus = vertx.eventBus();

       logger.info("Sending message to " + configuration.getProviderAddress() + " : " + message);
       eventBus.request(configuration.getProviderAddress(), message, ar -> {
           String result = ar.succeeded() ? ar.result().body().toString()  : "Error";
           logger.info("Received reply: " + result);
           socket.write(result);
       });
   });
}