Calling stompServer.close() has no effect

[mikadev]

Calling stompServer.rxClose() or stompServer.close() after server start listen has no effect on active connection and also accept new connections

public class StompWsBasic2 extends AbstractVerticle {
    private HttpServer httpServer;

    public static void main(String[] args) {
        Vertx.vertx().deployVerticle(new StompWsBasic2());
    }

    @Override
    public void start() throws Exception {
        super.start();

        StompServerHandler stompServerHandler = StompServerHandler.create(vertx);

        StompServer stompServer = StompServer.create(vertx, new StompServerOptions()
                        .setHeartbeat(new JsonObject().put("x", 5000).put("y", 5000))
                        .setPort(-1) // Disable the TCP port, optional
                        .setWebsocketBridge(true)// Enable the web socket support
                        .setWebsocketPath("/stomp"))
                .handler(stompServerHandler)
                .writingFrameHandler(sf -> {
                    System.out.println(sf.frame());
                });

        
        httpServer = vertx.createHttpServer(
                new HttpServerOptions().setWebSocketSubProtocols(Arrays.asList("v10.stomp", "v11.stomp", "v12.stomp"))
        );

        httpServer
                .webSocketHandler(stompServer.webSocketHandler())
                .listen(8087)
                .subscribe();

        vertx.setTimer(5000, e -> {
            stompServer.rxClose()
                    .doOnComplete(() -> System.err.println("close stompServer"))
                    .subscribe();
        });
    }
}

[tsegismont]

This is not a bug. In this case the stomp server is only used as bridge and no TCP server is started.

You should close the HTTP server to stop handling connections.

[mikadev]

Ok i understand thanks for replying, but what the purpose of the stompServer.rxClose() in this case ? (btw if i don't use timer the stomp will yes stopped and will not accept any further connection so are you sure about ?) @tsegismont

[tsegismont]

When used as a bridge for websockets, invoking close is not necessary (in fact, it doesn't perform any action).