Uses of Interface
io.fluxzero.sdk.common.websocket.WebsocketSession

Packages that use WebsocketSession

Package	Description
io.fluxzero.sdk.common.websocket

Uses of WebsocketSession in io.fluxzero.sdk.common.websocket

Methods in io.fluxzero.sdk.common.websocket that return WebsocketSession

Modifier and Type	Method	Description
WebsocketSession	JdkWebsocketConnector.connect(WebsocketEndpoint endpoint, WebsocketConnectionOptions options, URI uri)	Opens a native JDK WebSocket and adapts it to Fluxzero's low-level WebsocketSession contract.
WebsocketSession	WebsocketConnector.connect(WebsocketEndpoint endpoint, WebsocketConnectionOptions options, URI uri)	Opens a WebSocket connection to the given URI.
protected WebsocketSession	AbstractWebsocketClient.connectToServer(WebsocketConnector connector, URI endpointUri)
WebsocketSession	SessionPool.get()
protected WebsocketSession	SessionPool.get(int index)
WebsocketSession	SessionPool.get(String routingKey)

Methods in io.fluxzero.sdk.common.websocket that return types with arguments of type WebsocketSession

Modifier and Type	Method	Description
Set<WebsocketSession>	WebsocketSession.getOpenSessions()	Returns a snapshot of currently open sessions owned by the same connector.

Methods in io.fluxzero.sdk.common.websocket with parameters of type WebsocketSession

Modifier and Type	Method	Description
protected void	AbstractWebsocketClient.abort(WebsocketSession session, String reason)
protected CompressionAlgorithm	AbstractWebsocketClient.getCompressionAlgorithm(WebsocketSession session)
protected String	AbstractWebsocketClient.getNegotiatedSessionId(WebsocketSession session)
protected Optional<String>	AbstractWebsocketClient.getRuntimeVersion(WebsocketSession session)
protected WebSocketTransportFormat	AbstractWebsocketClient.getTransportFormat(WebsocketSession session)
protected void	AbstractWebsocketClient.handleClose(WebsocketSession session, WebsocketCloseReason closeReason)
protected void	AbstractWebsocketClient.handleError(WebsocketSession session, Throwable e)
protected void	AbstractWebsocketClient.handleMessage(byte[] bytes, WebsocketSession session, WebsocketEndpoint.ReceiveTiming receiveTiming)
protected void	AbstractWebsocketClient.handlePong(WebsocketSession session)
void	AbstractWebsocketClient.onClose(WebsocketSession session, WebsocketCloseReason closeReason)
void	WebsocketEndpoint.onClose(WebsocketSession session, WebsocketCloseReason closeReason)	Called once when a session closes or is aborted.
void	AbstractWebsocketClient.onError(WebsocketSession session, Throwable e)
void	WebsocketEndpoint.onError(WebsocketSession session, Throwable error)	Called when the underlying WebSocket implementation reports an error.
void	AbstractWebsocketClient.onMessage(byte[] bytes, WebsocketSession session)
void	AbstractWebsocketClient.onMessage(byte[] bytes, WebsocketSession session, WebsocketEndpoint.ReceiveTiming receiveTiming)
void	WebsocketEndpoint.onMessage(byte[] bytes, WebsocketSession session)	Called when a complete binary message has been received.
default void	WebsocketEndpoint.onMessage(byte[] bytes, WebsocketSession session, WebsocketEndpoint.ReceiveTiming receiveTiming)	Called when a complete binary message has been received, with low-level receive timing when available.
void	AbstractWebsocketClient.onOpen(WebsocketSession session)
void	WebsocketEndpoint.onOpen(WebsocketSession session)	Called after the opening handshake has completed and the session metadata is available.
void	AbstractWebsocketClient.onPong(ByteBuffer message, WebsocketSession session)
void	WebsocketEndpoint.onPong(ByteBuffer data, WebsocketSession session)	Called when a pong frame has been received.
protected AbstractWebsocketClient.PingRegistration	AbstractWebsocketClient.schedulePing(WebsocketSession session)
protected void	AbstractWebsocketClient.sendPing(WebsocketSession session)
protected WebSocketTransportCodec	AbstractWebsocketClient.transportCodec(WebsocketSession session)

Constructor parameters in io.fluxzero.sdk.common.websocket with type arguments of type WebsocketSession

Modifier	Constructor	Description
	SessionPool(int size, Supplier<WebsocketSession> sessionFactory)