Class JettyWebsocketRouter

java.lang.Object

io.fluxzero.testserver.websocket.JettyWebsocketRouter

public class JettyWebsocketRouter
extends Object

Embedded Jetty router for the test server's WebSocket endpoints and health check.

Constructor Summary

Constructors

Constructor	Description
JettyWebsocketRouter()

Method Summary

Modifier and Type	Method	Description
JettyWebsocketRouter	addRoute(String path, Function<ServerWebsocketSession, WebsocketEndpoint> endpointSupplier)	Registers a WebSocket route.
org.eclipse.jetty.server.Server	start(int port)	Starts Jetty on the given port.

Methods inherited from class Object

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

Constructor Details

JettyWebsocketRouter

public JettyWebsocketRouter()

Method Details

addRoute

public JettyWebsocketRouter addRoute(String path,
 Function<ServerWebsocketSession, WebsocketEndpoint> endpointSupplier)

Registers a WebSocket route.

Parameters:

path - route path, with or without leading/trailing slash

endpointSupplier - creates the Fluxzero endpoint for each accepted session

Returns:

this router

start

public org.eclipse.jetty.server.Server start(int port)
                                      throws Exception

Starts Jetty on the given port.

The server does not register Jetty's JVM shutdown hook. When the returned server is stopped, the router shuts down any endpoints it created.

Returns:

the started Jetty server, owned by the caller

Throws:

Exception