Class ProxyWebsocketEndpoint

java.lang.Object

io.fluxzero.proxy.ProxyWebsocketEndpoint

public class ProxyWebsocketEndpoint
extends Object

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor	Description
ProxyWebsocketEndpoint(Client client, RequestHandler requestHandler)

Method Summary

Modifier and Type	Method	Description
protected void	ensureStarted()
protected ProxyWebsocketEndpoint.SessionContext	getContext(io.fluxzero.proxy.ProxyWebsocketSession session)
protected void	handleDisconnects(List<SerializedMessage> resultMessages)
protected void	handleResultMessages(List<SerializedMessage> resultMessages)
void	onBinary(io.fluxzero.proxy.ProxyWebsocketSession session, byte[] message)
void	onClose(io.fluxzero.proxy.ProxyWebsocketSession session, WebsocketCloseReason closeReason)
void	onError(io.fluxzero.proxy.ProxyWebsocketSession session, Throwable error)
void	onOpen(io.fluxzero.proxy.ProxyWebsocketSession session)
void	onPong(io.fluxzero.proxy.ProxyWebsocketSession session, ByteBuffer message)
void	onText(io.fluxzero.proxy.ProxyWebsocketSession session, String message)
protected CompletableFuture<?>	sendCloseRequest(io.fluxzero.proxy.ProxyWebsocketSession session, WebsocketCloseReason closeReason)
protected CompletableFuture<?>	sendRequest(io.fluxzero.proxy.ProxyWebsocketSession 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

ProxyWebsocketEndpoint

public ProxyWebsocketEndpoint(Client client,
 RequestHandler requestHandler)

Method Details

onOpen

public void onOpen(io.fluxzero.proxy.ProxyWebsocketSession session)

onBinary

public void onBinary(io.fluxzero.proxy.ProxyWebsocketSession session,
 byte[] message)

onText

public void onText(io.fluxzero.proxy.ProxyWebsocketSession session,
 String message)

onPong

public void onPong(io.fluxzero.proxy.ProxyWebsocketSession session,
 ByteBuffer message)

onClose

public void onClose(io.fluxzero.proxy.ProxyWebsocketSession session,
 WebsocketCloseReason closeReason)

onError

public void onError(io.fluxzero.proxy.ProxyWebsocketSession session,
 Throwable error)

sendRequest

protected CompletableFuture<?> sendRequest(io.fluxzero.proxy.ProxyWebsocketSession session,
 String method,
 byte[] payload)

sendCloseRequest

protected CompletableFuture<?> sendCloseRequest(io.fluxzero.proxy.ProxyWebsocketSession session,
 WebsocketCloseReason closeReason)

handleResultMessages

protected void handleResultMessages(List<SerializedMessage> resultMessages)

handleDisconnects

protected void handleDisconnects(List<SerializedMessage> resultMessages)

getContext

protected ProxyWebsocketEndpoint.SessionContext getContext(io.fluxzero.proxy.ProxyWebsocketSession session)

ensureStarted

protected void ensureStarted()

shutDown

public void shutDown()