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, dydxStreamingService, FtxStreamingService, GateioStreamingService, GeminiProductStreamingService, HitbtcStreamingService, HuobiStreamingService, KrakenStreamingService, LgoStreamingService, OkCoinStreamingService, PoloniexStreamingService, SerumStreamingService

public abstract class JsonNettyStreamingService
extends NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
  • 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)