Class WebsocketEndpoint

java.lang.Object

jakarta.websocket.Endpoint

io.fluxzero.proxy.WebsocketEndpoint

public class WebsocketEndpoint
extends jakarta.websocket.Endpoint

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final record	WebsocketEndpoint.SessionContext

Constructor Summary

Constructors

Constructor	Description
WebsocketEndpoint(Client client, RequestHandler requestHandler)

Method Summary

Modifier and Type	Method	Description
protected void	ensureStarted()
protected WebsocketEndpoint.SessionContext	getContext(jakarta.websocket.Session session)
protected void	handleDisconnects(List<SerializedMessage> resultMessages)
protected void	handleResultMessages(List<SerializedMessage> resultMessages)
void	onClose(jakarta.websocket.Session session, jakarta.websocket.CloseReason closeReason)
void	onError(jakarta.websocket.Session session, Throwable error)
void	onOpen(jakarta.websocket.Session session, jakarta.websocket.EndpointConfig config)
protected CompletableFuture<?>	sendCloseRequest(jakarta.websocket.Session session, jakarta.websocket.CloseReason closeReason)
protected CompletableFuture<?>	sendRequest(jakarta.websocket.Session session, String method, byte[] payload)
void	shutDown()

Methods inherited from class Object

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

Constructor Details

WebsocketEndpoint

public WebsocketEndpoint(Client client,
 RequestHandler requestHandler)

Method Details

onOpen

public void onOpen(jakarta.websocket.Session session,
 jakarta.websocket.EndpointConfig config)

Specified by:

onOpen in class jakarta.websocket.Endpoint

onClose

public void onClose(jakarta.websocket.Session session,
 jakarta.websocket.CloseReason closeReason)

Overrides:

onClose in class jakarta.websocket.Endpoint

onError

public void onError(jakarta.websocket.Session session,
 Throwable error)

Overrides:

onError in class jakarta.websocket.Endpoint

sendRequest

protected CompletableFuture<?> sendRequest(jakarta.websocket.Session session,
 String method,
 byte[] payload)

sendCloseRequest

protected CompletableFuture<?> sendCloseRequest(jakarta.websocket.Session session,
 jakarta.websocket.CloseReason closeReason)

handleResultMessages

protected void handleResultMessages(List<SerializedMessage> resultMessages)

handleDisconnects

protected void handleDisconnects(List<SerializedMessage> resultMessages)

getContext

protected WebsocketEndpoint.SessionContext getContext(jakarta.websocket.Session session)

ensureStarted

protected void ensureStarted()

shutDown

public void shutDown()