T
- public abstract class AbstractWebsocketClient<T extends WsData> extends AbstractWebsocket<T>
Modifier and Type | Field and Description |
---|---|
static org.java_websocket.drafts.Draft |
DEFAULT_DRAFT |
static java.util.Map<java.lang.String,java.lang.String> |
NO_HTTP_HEADERS |
static java.net.Proxy |
NO_PROXY |
protected org.java_websocket.client.WebSocketClient |
ws |
Modifier | Constructor and Description |
---|---|
protected |
AbstractWebsocketClient(java.lang.String name,
java.net.URI serverUri) |
protected |
AbstractWebsocketClient(java.lang.String name,
java.net.URI serverUri,
org.java_websocket.drafts.Draft draft,
java.util.Map<java.lang.String,java.lang.String> httpHeaders,
java.net.Proxy proxy) |
protected |
AbstractWebsocketClient(java.lang.String name,
java.net.URI serverUri,
java.util.Map<java.lang.String,java.lang.String> httpHeaders) |
protected |
AbstractWebsocketClient(java.lang.String name,
java.net.URI serverUri,
java.util.Map<java.lang.String,java.lang.String> httpHeaders,
java.net.Proxy proxy) |
Modifier and Type | Method and Description |
---|---|
protected OnInternalError |
getOnInternalError()
Callback for internal error
|
boolean |
sendMessage(JsonrpcMessage message)
Sends a JSON-RPC message.
|
void |
sendMessageOrError(JsonrpcMessage message) |
java.util.concurrent.CompletableFuture<JsonrpcResponseSuccess> |
sendRequest(JsonrpcRequest request)
Sends a JSON-RPC Request and returns a future Response.
|
void |
start()
Starts the websocket client
|
void |
startBlocking()
Starts the websocket client
|
void |
stop()
Stops the websocket client
|
createWsData, getName, getOnClose, getOnError, getOnNotification, getOnOpen, getOnRequest, handleInternalErrorAsync, handleInternalErrorSync, logInfo, logWarn
public static final java.util.Map<java.lang.String,java.lang.String> NO_HTTP_HEADERS
public static final java.net.Proxy NO_PROXY
public static final org.java_websocket.drafts.Draft DEFAULT_DRAFT
protected final org.java_websocket.client.WebSocketClient ws
protected AbstractWebsocketClient(java.lang.String name, java.net.URI serverUri)
protected AbstractWebsocketClient(java.lang.String name, java.net.URI serverUri, java.util.Map<java.lang.String,java.lang.String> httpHeaders)
protected AbstractWebsocketClient(java.lang.String name, java.net.URI serverUri, java.util.Map<java.lang.String,java.lang.String> httpHeaders, java.net.Proxy proxy)
protected AbstractWebsocketClient(java.lang.String name, java.net.URI serverUri, org.java_websocket.drafts.Draft draft, java.util.Map<java.lang.String,java.lang.String> httpHeaders, java.net.Proxy proxy)
public void start()
public void startBlocking() throws java.lang.InterruptedException
java.lang.InterruptedException
public void stop()
protected OnInternalError getOnInternalError()
AbstractWebsocket
getOnInternalError
in class AbstractWebsocket<T extends WsData>
public void sendMessageOrError(JsonrpcMessage message) throws OpenemsException
OpenemsException
public boolean sendMessage(JsonrpcMessage message)
message
- public java.util.concurrent.CompletableFuture<JsonrpcResponseSuccess> sendRequest(JsonrpcRequest request) throws OpenemsError.OpenemsNamedException
request
- the JSON-RPC RequestOpenemsError.OpenemsNamedException
- on error