Package no.polaric.core.httpd

Class NodeWs

java.lang.Object

no.polaric.core.httpd.ServerBase

no.polaric.core.httpd.WsNotifier

no.polaric.core.httpd.NodeWs

All Implemented Interfaces:

SesNotifier

public class NodeWs
extends WsNotifier

WebSocket communiction between server nodes.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	NodeWs.Client

Nested classes/interfaces inherited from interface no.polaric.core.httpd.SesNotifier

SesNotifier.SHandler

Field Summary

Fields inherited from class no.polaric.core.httpd.WsNotifier

_clients

Fields inherited from class no.polaric.core.httpd.ServerBase

_conf, _encoding, a, localTime, mapper, utcTime

Constructor Summary

Constructors

Constructor	Description
NodeWs(ServerConfig conf, NodeWsApi.Handler<String> hdl)

Method Summary

Modifier and Type	Method	Description
Set<String>	getSubscribers()	Get set of subcriber-ids
WsNotifier.Client	newClient(io.javalin.websocket.WsContext conn)	Factory method.
boolean	put(String nodeid, Object obj)	Post a object to a node (JSON encoded)
boolean	putText(String nodeid, String msg)	Post a message to node.
void	removeSubscriber(String id)	Remove a subscriber
void	setHandler(NodeWsApi.Handler<String> h)

Methods inherited from class no.polaric.core.httpd.WsNotifier

authenticate, clients, closeSes, nClients, nLoggedIn, nLogins, nVisits, onCloseSes, onOpenSes, postText, postText, sesId, start, subscribe

Methods inherited from class no.polaric.core.httpd.ServerBase

addSubtype, cleanPath, clientIpAddr, conf, deserializeJson, fixText, fromJson, getAuthInfo, icon, metaTag, protect, protect, roundDeg, serializeJson, systemNotification, toJson, urlDecode, wServer

Methods inherited from class java.lang.Object

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

Constructor Details

NodeWs

public NodeWs(ServerConfig conf,
 NodeWsApi.Handler<String> hdl)

Method Details

getSubscribers

public Set<String> getSubscribers()

Get set of subcriber-ids

removeSubscriber

public void removeSubscriber(String id)

Remove a subscriber

setHandler

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

putText

public boolean putText(String nodeid,
 String msg)

Post a message to node. Returns true if sending was successful.

put

public boolean put(String nodeid,
 Object obj)

Post a object to a node (JSON encoded)

newClient

public WsNotifier.Client newClient(io.javalin.websocket.WsContext conn)

Factory method.

Specified by:

newClient in class WsNotifier