services.moleculer.httpclient

Class WebSocketParams

java.lang.Object

org.asynchttpclient.RequestBuilderBase<WebSocketParams>

services.moleculer.httpclient.WebSocketParams

public class WebSocketParams
extends org.asynchttpclient.RequestBuilderBase<WebSocketParams>

WebSocket message receiver with built-in heartbeat function. Usage:

 client.ws("ws://server/path", msg -> {
 
     // Message received; "msg" is a JSON structure
     String value = msg.get("key", "defaultValue");
 
 }, params -> {
 
     // Configure connection
     params.setHeartbeatInterval(60);
     params.setHeader("key", "value");
 
 });
 

Field Summary

Fields

Modifier and Type	Field and Description
protected int	heartbeatInterval
protected int	heartbeatTimeout
protected int	reconnectDelay

Fields inherited from class org.asynchttpclient.RequestBuilderBase

address, bodyGenerator, bodyParts, byteBufferData, byteData, channelPoolPartitioning, charset, compositeByteData, cookies, DEFAULT_NAME_RESOLVER, file, followRedirect, formParams, headers, localAddress, method, nameResolver, proxyServer, queryParams, rangeOffset, readTimeout, realm, requestTimeout, signatureCalculator, streamData, stringData, uri, uriEncoder, virtualHost

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	WebSocketParams(boolean isDisableUrlEncoding)

Method Summary

Modifier and Type	Method and Description
WebSocketParams	setHeartbeatInterval(int heartbeatInterval)
WebSocketParams	setHeartbeatTimeout(int heartbeatTimeout)
WebSocketParams	setReconnectDelay(int reconnectDelay)

Methods inherited from class org.asynchttpclient.RequestBuilderBase

addBodyPart, addCookie, addFormParam, addHeader, addHeader, addHeader, addOrReplaceCookie, addQueryParam, addQueryParams, build, clearHeaders, resetCookies, resetFormParams, resetMultipartData, resetNonMultipartData, resetQuery, setAddress, setBody, setBody, setBody, setBody, setBody, setBody, setBody, setBody, setBody, setBodyParts, setChannelPoolPartitioning, setCharset, setCookies, setFollowRedirect, setFormParams, setFormParams, setHeader, setHeader, setHeader, setHeaders, setHeaders, setLocalAddress, setMethod, setNameResolver, setProxyServer, setProxyServer, setQueryParams, setQueryParams, setRangeOffset, setReadTimeout, setRealm, setRealm, setRequestTimeout, setSignatureCalculator, setSingleHeaders, setUri, setUrl, setVirtualHost

Methods inherited from class java.lang.Object

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

Field Detail

heartbeatInterval

protected int heartbeatInterval

heartbeatTimeout

protected int heartbeatTimeout

reconnectDelay

protected int reconnectDelay

Constructor Detail

WebSocketParams

protected WebSocketParams(boolean isDisableUrlEncoding)

Method Detail

setHeartbeatInterval

public WebSocketParams setHeartbeatInterval(int heartbeatInterval)

setHeartbeatTimeout

public WebSocketParams setHeartbeatTimeout(int heartbeatTimeout)

setReconnectDelay

public WebSocketParams setReconnectDelay(int reconnectDelay)