Uses of Interface
io.fluxzero.testserver.websocket.ServerWebsocketSession

Packages that use ServerWebsocketSession

Package	Description
io.fluxzero.testserver.websocket

Uses of ServerWebsocketSession in io.fluxzero.testserver.websocket

Methods in io.fluxzero.testserver.websocket with parameters of type ServerWebsocketSession

Modifier and Type	Method	Description
protected void	WebsocketEndpoint.abort(ServerWebsocketSession session, String reason)
protected Stream<Runnable>	WebsocketEndpoint.createTasks(RequestBatch<?> batch, ServerWebsocketSession session)
protected Stream<Runnable>	WebsocketEndpoint.createTasks(RequestBatch<?> batch, ServerWebsocketSession session, long requestReceivedTimestamp)
protected JsonType	WebsocketEndpoint.deserializeRequest(ServerWebsocketSession session, byte[] bytes)
protected void	WebsocketEndpoint.dispatchRequest(ServerWebsocketSession session, JsonType request)
protected void	WebsocketEndpoint.dispatchRequest(ServerWebsocketSession session, JsonType request, long requestReceivedTimestamp)
protected void	WebsocketEndpoint.doSendResult(ServerWebsocketSession session, RequestResult result)
protected Optional<WebsocketEndpoint.SessionBacklog>	WebsocketEndpoint.findAlternativeBacklog(ServerWebsocketSession closedSession)
protected String	WebsocketEndpoint.getClientId(ServerWebsocketSession session)
protected String	WebsocketEndpoint.getClientName(ServerWebsocketSession session)
protected String	WebsocketEndpoint.getClientSdkVersion(ServerWebsocketSession session)
protected CompressionAlgorithm	WebsocketEndpoint.getCompressionAlgorithm(ServerWebsocketSession session)
static String	WebsocketDeploymentUtils.getNamespace(ServerWebsocketSession session)	Resolves the test-server namespace from modern namespace or legacy projectId query parameters.
protected String	WebsocketEndpoint.getNamespace(ServerWebsocketSession session)
protected String	WebsocketEndpoint.getNegotiatedSessionId(ServerWebsocketSession session)
protected Map<String, List<String>>	WebsocketEndpoint.getRequestHeaders(ServerWebsocketSession session)
protected WebSocketTransportFormat	WebsocketEndpoint.getTransportFormat(ServerWebsocketSession session)
protected void	WebsocketEndpoint.handleMessage(ServerWebsocketSession session, JsonType message)
protected void	WebsocketEndpoint.handleMessage(ServerWebsocketSession session, JsonType message, long requestReceivedTimestamp)
void	ConsumerEndpoint.onClose(ServerWebsocketSession session, WebsocketCloseReason closeReason)
void	WebsocketEndpoint.onClose(ServerWebsocketSession session, WebsocketCloseReason closeReason)
void	WebsocketEndpoint.onError(ServerWebsocketSession session, Throwable e)
void	WebsocketEndpoint.onMessage(byte[] bytes, ServerWebsocketSession session)
void	WebsocketEndpoint.onOpen(ServerWebsocketSession session)
void	WebsocketEndpoint.onPong(ByteBuffer message, ServerWebsocketSession session)
protected void	WebsocketEndpoint.registerMetrics(Object event, ServerWebsocketSession session)
protected WebsocketEndpoint.PingRegistration	WebsocketEndpoint.schedulePing(ServerWebsocketSession session)
protected void	WebsocketEndpoint.sendPing(ServerWebsocketSession session)
protected void	WebsocketEndpoint.sendResultBatch(ServerWebsocketSession session, List<RequestResult> results)
protected CompletableFuture<Void>	WebsocketEndpoint.sendResultBatchAsync(ServerWebsocketSession session, List<RequestResult> results)
protected Metadata	WebsocketEndpoint.sessionMetadata(ServerWebsocketSession session)
protected boolean	WebsocketEndpoint.submitRequestTask(ServerWebsocketSession session, JsonType request, Runnable task)
protected WebSocketTransportCodec	WebsocketEndpoint.transportCodec(ServerWebsocketSession session)

Method parameters in io.fluxzero.testserver.websocket with type arguments of type ServerWebsocketSession

Modifier and Type	Method	Description
JettyWebsocketRouter	JettyWebsocketRouter.addRoute(String path, Function<ServerWebsocketSession, WebsocketEndpoint> endpointSupplier)	Registers a WebSocket route.
static JettyWebsocketRouter	WebsocketDeploymentUtils.deployFromSession(MemoizingFunction<ServerWebsocketSession, WebsocketEndpoint> endpointSupplier, String path, JettyWebsocketRouter router)	Registers a route whose endpoint can be resolved from the complete WebSocket session.