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
-
Field Details
-
objectMapper
protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper
-
-
Constructor Details
-
JsonNettyStreamingService
-
JsonNettyStreamingService
-
JsonNettyStreamingService
-
-
Method Details
-
processArrayMessageSeparately
public boolean processArrayMessageSeparately() -
messageHandler
Description copied from class:NettyStreamingService
Handler that receives incoming messages.- Specified by:
messageHandler
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
- Parameters:
message
- Content of the message from the server.
-
sendObjectMessage
-