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(io.fluxzero.sdk.configuration.client.Client client, io.fluxzero.sdk.publishing.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<io.fluxzero.common.api.SerializedMessage> resultMessages)
protected void	handleResultMessages(List<io.fluxzero.common.api.SerializedMessage> resultMessages)
void	onBinary(io.fluxzero.proxy.ProxyWebsocketSession session, byte[] message)
void	onClose(io.fluxzero.proxy.ProxyWebsocketSession session, io.fluxzero.sdk.common.websocket.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, io.fluxzero.sdk.common.websocket.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(io.fluxzero.sdk.configuration.client.Client client,
 io.fluxzero.sdk.publishing.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,
 io.fluxzero.sdk.common.websocket.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,
 io.fluxzero.sdk.common.websocket.WebsocketCloseReason closeReason)

handleResultMessages

protected void handleResultMessages(List<io.fluxzero.common.api.SerializedMessage> resultMessages)

handleDisconnects

protected void handleDisconnects(List<io.fluxzero.common.api.SerializedMessage> resultMessages)

getContext

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

ensureStarted

protected void ensureStarted()

shutDown

public void shutDown()