EventBus.java

public void start(Future<Void> startFuture) {
	//Retrieve the EventBus object form the vertx one
	EventBus eventBus = vertx.eventBus();

	//Create a EventBus consumer and instantiate a JsonObject type message consumer
	MessageConsumer<JsonObject> createConsumer = eventBus.consumer("customer.create");
	
	//Handle new messages on customer.create endpoint
	createConsumer.handler(json -> {
		System.out.println("Received new customer: " + json.body());
		//Enrich the customer object
		JsonObject enrichedCustomer = enrichCustomer(json.body());
		
		//Publish (one-to-many) the enriched message on another endpoint
		eventBus.publish("customer.completion", enrichedCustomer);
	});
	
	startFuture.complete();
}