public abstract class AbstractWebsocketServer<T extends WsData> extends AbstractWebsocket<T>
Modifier | Constructor and Description |
---|---|
protected |
AbstractWebsocketServer(java.lang.String name,
int port) |
Modifier and Type | Method and Description |
---|---|
void |
broadcastMessage(JsonrpcMessage message)
Broadcasts a message to all connected WebSockets.
|
java.util.Collection<org.java_websocket.WebSocket> |
getConnections() |
protected OnInternalError |
getOnInternalError()
Callback for internal error
|
protected JsonrpcMessage |
handleNonJsonrpcMessage(java.lang.String stringMessage,
OpenemsError.OpenemsNamedException e)
Convert deprecated Non-JSON-RPC messages to JSON-RPC messages.
|
void |
sendMessage(org.java_websocket.WebSocket ws,
JsonrpcMessage message)
Sends a message to WebSocket.
|
void |
start()
Starts the websocket server
|
void |
stop()
Stops the websocket server
|
createWsData, getName, getOnClose, getOnError, getOnNotification, getOnOpen, getOnRequest, handleInternalErrorAsync, handleInternalErrorSync, logInfo, logWarn
protected AbstractWebsocketServer(java.lang.String name, int port)
name
- to identify this serverport
- to listen onprotected OnInternalError getOnInternalError()
AbstractWebsocket
getOnInternalError
in class AbstractWebsocket<T extends WsData>
public java.util.Collection<org.java_websocket.WebSocket> getConnections()
public void sendMessage(org.java_websocket.WebSocket ws, JsonrpcMessage message)
ws
- the WebSocketmessage
- the JSON-RPC Messagepublic void broadcastMessage(JsonrpcMessage message)
message
- the JSON-RPC Messagepublic void start()
public void stop()
protected JsonrpcMessage handleNonJsonrpcMessage(java.lang.String stringMessage, OpenemsError.OpenemsNamedException e) throws OpenemsError.OpenemsNamedException
stringMessage
- OpenemsError.OpenemsNamedException