package com.roothema.vertx.eventbus.subscribe.sample;

import org.vertx.java.core.Handler;
import org.vertx.java.core.Vertx;
import org.vertx.java.core.eventbus.Message;
import org.vertx.java.core.json.JsonObject;

/**
 * Created by roothema on 2015.01.17..
 */
public class BusReader implements Handler<Message<JsonObject>> {

    @Override
    public void handle(Message<JsonObject> message) {
        System.out.println("\n\n----------------");
        System.out.println("Address: " + message.address());
        System.out.println("Received message from news-feed queue: " + message.body());
    }
}
