Skip to content

Instantly share code, notes, and snippets.

@oxsav
Last active December 15, 2015 14:09
Show Gist options
  • Save oxsav/5272507 to your computer and use it in GitHub Desktop.
Save oxsav/5272507 to your computer and use it in GitHub Desktop.
import org.vertx.java.platform.Verticle;
import org.vertx.java.busmods.BusModBase;
import org.vertx.java.core.Handler;
import org.vertx.java.core.eventbus.Message;
import org.vertx.java.core.json.JsonArray;
import org.vertx.java.core.json.JsonObject;
public class Presence extends BusModBase implements Handler<Message<JsonObject>> {
protected String address;
protected String host;
protected int port;
public void start() {
System.out.println("Presence Module started");
super.start();
address = getOptionalStringConfig("address", "presence");
host = getOptionalStringConfig("host", "localhost");
port = getOptionalIntConfig("port", 3080);
eb.registerHandler(address, this);
}
public void handle(Message<JsonObject> message) {
String action = message.body.getString("action");
if (action == null) {
sendError(message, "action must be specified");
return;
}
switch (action) {
case "get":
getStates(message);
break;
default:
sendError(message, "Invalid action: " + action);
return;
}
}
private void getStates(Message<JsonObject> message) {
//String action = getMandatoryString("action", message);
JsonObject objReply = new JsonObject();
objReply.putString("reply", "reply");
message.reply(objReply);
//sendOK(message,objReply);
}
public void stop() {
}
}
/////
java.lang.NoSuchMethodError: org.vertx.java.core.eventbus.Message.reply(Lorg/vertx/java/core/json/JsonObject;)V
at com.presenceModule.presence.Presence.getStates(Presence.java:123)
at com.presenceModule.presence.Presence.handle(Presence.java:64)
at com.presenceModule.presence.Presence.handle(Presence.java:27)
at org.vertx.java.core.eventbus.impl.DefaultEventBus$7.run(DefaultEventBus.java:592)
at org.vertx.java.core.impl.Context$2.run(Context.java:119)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.processEventQueue(AbstractNioWorker.java:454)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:331)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:35)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:722)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment