Skip to content

Instantly share code, notes, and snippets.

@darylteo
Created June 27, 2012 05:00
Show Gist options
  • Save darylteo/3001599 to your computer and use it in GitHub Desktop.
Save darylteo/3001599 to your computer and use it in GitHub Desktop.
EventBus message body type
load('vertx.js');
var eb = vertx.eventBus;
vertx.setPeriodic(1000,function(id){
eb.send(
'server.address',
'a String',
function(reply){
console.log(reply);
}
);
);
import org.vertx.java.core.*;
import org.vertx.java.core.eventbus.*;
import org.vertx.java.core.json.*;
import org.vertx.java.deploy.*;
public class server extends Verticle {
public void start(){
EventBus eb = vertx.eventBus();
eb.registerHandler(
"server.address",
new Handler<Message<JsonObject>>(){
public void handle(Message<JsonObject> message){
System.out.println(message.body);
JsonObject body = message.body;
System.out.println(body.getString(""));
JsonObject object =
new JsonObject("{ \"reply\":\"message\" }");
message.reply(object);
}
}
);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment