beders

bus.register(msg -> { System.out.println("I gots a message") });
bus.register((msg,param) -> { System.out.println("I gots a message w/ params"); });

beders

package com.saffrontech.vertx;

import io.vertx.core.AsyncResult;
import io.vertx.core.Handler;
import io.vertx.core.MultiMap;
import io.vertx.core.Vertx;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.eventbus.DeliveryOptions;
import io.vertx.core.eventbus.Message;
import io.vertx.core.http.WebSocket;

beders

package com.saffrontech.ws.vertx.problem;

import io.vertx.core.AbstractVerticle;
import io.vertx.core.DeploymentOptions;
import io.vertx.core.Vertx;
import io.vertx.ext.apex.Router;
import io.vertx.ext.apex.handler.sockjs.BridgeOptions;
import io.vertx.ext.apex.handler.sockjs.SockJSHandler;

// curl http://localhost:8888/eventbus/info

beders

// run with: curl -d 'console.log("hi");' http://localhost:8063; curl -d 'console.log("hi");' http://localhost:8063
vertx.createHttpServer().requestHandler(function (req) {
    req.bodyHandler(function (buffer) {
        var code = buffer.toString("UTF-8");
        var result = eval('"use strict";' + code) || {};
        req.response().end(JSON.stringify(result));
    });
}).listen(8063);