Package io.quarkus.websockets.next.runtime.dev.ui

Class WebSocketNextJsonRPCService

java.lang.Object

io.quarkus.websockets.next.runtime.dev.ui.WebSocketNextJsonRPCService

All Implemented Interfaces:

io.quarkus.websockets.next.runtime.ConnectionManager.ConnectionListener

@ApplicationScoped
public class WebSocketNextJsonRPCService
extends Object
implements io.quarkus.websockets.next.runtime.ConnectionManager.ConnectionListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final record	WebSocketNextJsonRPCService.DevWebSocket
(package private) static final record	WebSocketNextJsonRPCService.TextMessage

Constructor Summary

Constructors

Constructor	Description
WebSocketNextJsonRPCService(jakarta.enterprise.inject.Instance<io.quarkus.websockets.next.runtime.ConnectionManager> connectionManager, io.vertx.core.Vertx vertx, io.quarkus.vertx.http.runtime.VertxHttpConfig httpConfig, io.quarkus.websockets.next.runtime.config.WebSocketsServerRuntimeConfig config)

Method Summary

Modifier and Type	Method	Description
io.vertx.core.json.JsonObject	clearMessages(String connectionKey)
io.smallrye.mutiny.Uni<io.vertx.core.json.JsonObject>	closeDevConnection(String connectionKey)
void	connectionAdded(String endpoint, io.quarkus.websockets.next.WebSocketConnection connection)
io.smallrye.mutiny.Multi<io.vertx.core.json.JsonObject>	connectionMessages()
void	connectionRemoved(String endpoint, String connectionId)
io.smallrye.mutiny.Multi<io.vertx.core.json.JsonObject>	connectionStatus()
io.vertx.core.json.JsonObject	getConnections(List<String> endpoints)
io.vertx.core.json.JsonArray	getMessages(String connectionKey)
(package private) static boolean	isInvalidPath(String path, String endpointPath)
io.smallrye.mutiny.Uni<io.vertx.core.json.JsonObject>	openDevConnection(String path, String endpointPath)
io.smallrye.mutiny.Uni<io.vertx.core.json.JsonObject>	sendTextMessage(String connectionKey, String message)
(package private) io.vertx.core.json.JsonObject	toJsonObject(String endpoint, io.quarkus.websockets.next.WebSocketConnection c)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WebSocketNextJsonRPCService

WebSocketNextJsonRPCService(jakarta.enterprise.inject.Instance<io.quarkus.websockets.next.runtime.ConnectionManager> connectionManager,
 io.vertx.core.Vertx vertx,
 io.quarkus.vertx.http.runtime.VertxHttpConfig httpConfig,
 io.quarkus.websockets.next.runtime.config.WebSocketsServerRuntimeConfig config)

Method Details

connectionStatus

public io.smallrye.mutiny.Multi<io.vertx.core.json.JsonObject> connectionStatus()

connectionMessages

public io.smallrye.mutiny.Multi<io.vertx.core.json.JsonObject> connectionMessages()

getConnections

public io.vertx.core.json.JsonObject getConnections(List<String> endpoints)

getMessages

public io.vertx.core.json.JsonArray getMessages(String connectionKey)

openDevConnection

public io.smallrye.mutiny.Uni<io.vertx.core.json.JsonObject> openDevConnection(String path,
 String endpointPath)

isInvalidPath

static boolean isInvalidPath(String path,
 String endpointPath)

closeDevConnection

public io.smallrye.mutiny.Uni<io.vertx.core.json.JsonObject> closeDevConnection(String connectionKey)

sendTextMessage

public io.smallrye.mutiny.Uni<io.vertx.core.json.JsonObject> sendTextMessage(String connectionKey,
 String message)

clearMessages

public io.vertx.core.json.JsonObject clearMessages(String connectionKey)

connectionAdded

public void connectionAdded(String endpoint,
 io.quarkus.websockets.next.WebSocketConnection connection)

Specified by:

connectionAdded in interface io.quarkus.websockets.next.runtime.ConnectionManager.ConnectionListener

connectionRemoved

public void connectionRemoved(String endpoint,
 String connectionId)

Specified by:

connectionRemoved in interface io.quarkus.websockets.next.runtime.ConnectionManager.ConnectionListener

toJsonObject

io.vertx.core.json.JsonObject toJsonObject(String endpoint,
 io.quarkus.websockets.next.WebSocketConnection c)