Package info.bitrich.xchangestream.service.netty

Class JsonNettyStreamingService

java.lang.Object

info.bitrich.xchangestream.service.ConnectableService

info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

info.bitrich.xchangestream.service.netty.JsonNettyStreamingService

Direct Known Subclasses:

BankeraStreamingService, BinanceStreamingService, BinanceUserDataStreamingService, BitfinexStreamingService, BitmexStreamingService, BitstampStreamingService, CexioStreamingRawService, CoinbaseProStreamingService, CoincheckStreamingService, dydxStreamingService, FtxStreamingService, GateioStreamingService, GeminiProductStreamingService, HitbtcStreamingService, HuobiStreamingService, KrakenStreamingService, LgoStreamingService, OkCoinStreamingService, OkexStreamingService, PoloniexStreamingService, SerumStreamingService

public abstract class JsonNettyStreamingService
extends NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

Nested Class Summary

Nested classes/interfaces inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService

NettyStreamingService.NettyWebSocketClientHandler, NettyStreamingService.Subscription

Field Summary

Fields

Modifier and Type	Field	Description
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Fields inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService

channels, DEFAULT_CONNECTION_TIMEOUT, DEFAULT_IDLE_TIMEOUT, DEFAULT_RETRY_DURATION, uri

Fields inherited from class info.bitrich.xchangestream.service.ConnectableService

BEFORE_CONNECTION_HANDLER

Constructor Summary

Constructors

Constructor	Description
JsonNettyStreamingService(String apiUrl)
JsonNettyStreamingService(String apiUrl, int maxFramePayloadLength)
JsonNettyStreamingService(String apiUrl, int maxFramePayloadLength, Duration connectionTimeout, Duration retryDuration, int idleTimeoutSeconds)

Method Summary

Modifier and Type	Method	Description
void	messageHandler(String message)	Handler that receives incoming messages.
boolean	processArrayMessageSeparately()
protected void	sendObjectMessage(Object message)

Methods inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService

disconnect, getChannel, getChannelNameFromMessage, getCustomHeaders, getSubscribeMessage, getSubscriptionUniqueId, getUnsubscribeMessage, getWebSocketClientExtensionHandler, getWebSocketClientHandler, handleChannelError, handleChannelMessage, handleError, handleIdle, handleMessage, isSocketOpen, openConnection, resubscribeChannels, sendMessage, setAcceptAllCertificates, setAutoReconnect, setEnableLoggingHandler, setLoggingHandlerLevel, setSocksProxyHost, setSocksProxyPort, subscribeChannel, subscribeConnectionState, subscribeConnectionSuccess, subscribeDisconnect, subscribeIdle, subscribeReconnectFailure, useCompressedMessages

Methods inherited from class info.bitrich.xchangestream.service.ConnectableService

connect, setBeforeConnectionHandler

Methods inherited from class java.lang.Object

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

Field Details

objectMapper

protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Details

JsonNettyStreamingService

public JsonNettyStreamingService(String apiUrl)

JsonNettyStreamingService

public JsonNettyStreamingService(String apiUrl,
int maxFramePayloadLength)

JsonNettyStreamingService

public JsonNettyStreamingService(String apiUrl,
int maxFramePayloadLength,
Duration connectionTimeout,
Duration retryDuration,
int idleTimeoutSeconds)

Method Details

processArrayMessageSeparately

public boolean processArrayMessageSeparately()

messageHandler

public void messageHandler(String message)

Description copied from class: NettyStreamingService

Handler that receives incoming messages.

Specified by:

messageHandler in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

Parameters:

message - Content of the message from the server.

sendObjectMessage

protected void sendObjectMessage(Object message)