EventBus onOpen Pub Subscribe with vertx3-eventbus-client

[axlider]

Hi,

i try to get data from server by listening to EventBus with SockJsHandler.
But my onopen function is never called.
In the network tab of chrome i can see these connection entries:

info?t=1490613267837 200 xhr abstract-xhr.js:128 367 B 19 ms
info?t=1490613267847 (canceled) xhr abstract-xhr.js:128 0 B 7.98 s
websocket 101 websocket websocket.js:32 0 B Pending

My application (webpack) runs on "https://localhost:3000" and listens to "http://localhost:8080/eventbus"

Server side code

`import java.util.concurrent.ExecutionException;

import io.vertx.core.Vertx;
import io.vertx.core.eventbus.EventBus;
import io.vertx.core.http.HttpMethod;
import io.vertx.core.http.HttpServerRequest;
import io.vertx.ext.web.Router;
import io.vertx.ext.web.handler.sockjs.BridgeOptions;
import io.vertx.ext.web.handler.sockjs.PermittedOptions;
import io.vertx.ext.web.handler.sockjs.SockJSHandler;

public class Server {

public void start(Vertx vertx, String host, int port) throws InterruptedException, ExecutionException {
	vertx.createHttpServer().requestHandler(httpRequest -> handleHttpRequest(vertx, httpRequest)).listen(8080);

	Router router = Router.router(vertx);
	SockJSHandler sockJSHandler = SockJSHandler.create(vertx);
	BridgeOptions options = new BridgeOptions();
	options.addInboundPermitted(new PermittedOptions().setAddress("vehicleData"));
	options.addOutboundPermitted(new PermittedOptions().setAddress("vehicleData"));
	sockJSHandler.bridge(options);

	router.route("/eventbus/*").handler(sockJSHandler);
	// router.route().handler(io.vertx.ext.web.handler.CorsHandler.create("vertx\\.io").allowedMethod(HttpMethod.GET));
	router.route().handler(io.vertx.ext.web.handler.CorsHandler.create("*").allowedMethod(HttpMethod.GET));
	router.route().handler(io.vertx.ext.web.handler.CorsHandler.create("*").allowedMethod(HttpMethod.POST));
	
	EventBus eb = vertx.eventBus();

	vertx.setPeriodic(5000, v -> {
		eb.publish("vehicleData", getMessage());
		eb.send("vehicleData", getMessage());
		System.out.println("message sent ");
	});
}

private void handleHttpRequest(Vertx vertx, final HttpServerRequest httpRequest) {
	System.out.println("request handler");
}

public static void main(String[] args) throws InterruptedException, ExecutionException {
	Vertx vertx = Vertx.vertx();
	new Server().start(vertx, "localhost", 8080);
}

private String getMessage() {
		return "{\r\n" + 
			"   \"vehicles\": [\r\n" + 
			"      {\r\n" + 
			"         \"id\": \"1\",\r\n" + 
			"         \"vehicleid\": \"P110001\",\r\n" + 
			"         \"type\": \"N 5217 SHD\",\r\n" + 
			"         \"range\": \"BUSR\",\r\n" + 
			"         \"typekey\": \"N 5217 SHD\"\r\n" + 
			"      },\r\n" + 
			"      {\r\n" + 
			"         \"id\": \"2\",\r\n" + 
			"         \"vehicleid\": \"P110002\",\r\n" + 
			"         \"type\": \"N 5217 SHD\",\r\n" + 
			"         \"range\": \"BUSR\",\r\n" + 
			"         \"typekey\": \"N 5217 SHD\"\r\n" + 
			"      },\r\n" + 
			"      {\r\n" + 
			"         \"id\": \"3\",\r\n" + 
			"         \"vehicleid\": \"P110003\",\r\n" + 
			"         \"type\": \"N 5217 SHD\",\r\n" + 
			"         \"range\": \"BUSR\",\r\n" + 
			"         \"typekey\": \"N 5217 SHD\"\r\n" + 
			"      }\r\n" + 
			"   ]\r\n" + 
			"}";
}

}

Javascript code

`
const receiveEvents = function() {

var eb = new EventBus('http://localhost:8080/eventbus');

eb.onopen = () => {

    // set a handler to receive a message
    //eb.registerHandler('http://localhst:8080/vehicles/getVehicles', (error, message) => {
    eb.registerHandler('vehicleData', (error, message) => {
        console.log(`received a message: ${JSON.stringify(message)}`);
    });

    // send a message
    //eb.send('some-address', {name: 'tim', age: 587});
}
eb.onerror = function(e) {
    console.log('General error: ', e); // this does happen
}

}
receiveEvents();

`

thanks for any suggestions!

[axlider]

my fault. forgot to call : router.accept(httpRequest);
Everything works fine!