Package no.polaric.core.httpd

Class NodeWsClient

java.lang.Object

no.polaric.core.httpd.NodeWsClient

All Implemented Interfaces:

WebSocket.Listener

public class NodeWsClient
extends Object
implements WebSocket.Listener

Client side of websocket.

Constructor Summary

Constructors

Constructor	Description
NodeWsClient(ServerConfig conf, String nodeid, String url, boolean retry)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	isConnected()
CompletionStage<?>	onClose(WebSocket webSocket, int statusCode, String reason)
void	onError(WebSocket webSocket, Throwable error)
void	onOpen(WebSocket webSocket)
CompletionStage<?>	onText(WebSocket webSocket, CharSequence data, boolean last)
void	open()
boolean	put(Object obj)	Post a object to the connected node (JSON encoded)
boolean	putCommand(String cmd, String msg)
boolean	putText(String msg)
void	setHandler(NodeWsApi.Handler<String> h)
void	setUserid(String id)
boolean	subscribe(String nodeid)
void	unsubscribe()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.net.http.WebSocket.Listener

onBinary, onPing, onPong

Constructor Details

NodeWsClient

public NodeWsClient(ServerConfig conf,
 String nodeid,
 String url,
 boolean retry)

Method Details

setUserid

public void setUserid(String id)

setHandler

public void setHandler(NodeWsApi.Handler<String> h)

open

public void open()

close

public void close()

isConnected

public boolean isConnected()

subscribe

public boolean subscribe(String nodeid)

unsubscribe

public void unsubscribe()

putCommand

public boolean putCommand(String cmd,
 String msg)

putText

public boolean putText(String msg)

put

public boolean put(Object obj)

Post a object to the connected node (JSON encoded)

onError

public void onError(WebSocket webSocket,
 Throwable error)

Specified by:

onError in interface WebSocket.Listener

onOpen

public void onOpen(WebSocket webSocket)

Specified by:

onOpen in interface WebSocket.Listener

onClose

public CompletionStage<?> onClose(WebSocket webSocket,
 int statusCode,
 String reason)

Specified by:

onClose in interface WebSocket.Listener

onText

public CompletionStage<?> onText(WebSocket webSocket,
 CharSequence data,
 boolean last)

Specified by:

onText in interface WebSocket.Listener