Package net.finmath.smartcontract.valuation.service.websocket.client

Class WebSocketClientEndpoint

java.lang.Object

jakarta.websocket.Endpoint

net.finmath.smartcontract.valuation.service.websocket.client.WebSocketClientEndpoint

public class WebSocketClientEndpoint
extends jakarta.websocket.Endpoint

Client End point for demo purposes, currently just printing the text messages on console

Author:

Peter Kohl-Landgraf

Constructor Summary

Constructors

Constructor	Description
WebSocketClientEndpoint(URI endpointURI, String user, String password)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Observable<String>	asObservable()
jakarta.websocket.Session	getUserSession()
void	onClose(jakarta.websocket.Session userSession, jakarta.websocket.CloseReason reason)
void	onOpen(jakarta.websocket.Session session, jakarta.websocket.EndpointConfig config)
void	sendTextMessage(String message)

Methods inherited from class jakarta.websocket.Endpoint

onError

Methods inherited from class java.lang.Object

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

Constructor Details

WebSocketClientEndpoint

public WebSocketClientEndpoint(URI endpointURI,
 String user,
 String password)

Method Details

getUserSession

public jakarta.websocket.Session getUserSession()

asObservable

public io.reactivex.rxjava3.core.Observable<String> asObservable()

sendTextMessage

public void sendTextMessage(String message)
                     throws IOException

Throws:

IOException

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 userSession,
 jakarta.websocket.CloseReason reason)

Overrides:

onClose in class jakarta.websocket.Endpoint