Package info.bitrich.xchangestream.kraken

Class KrakenStreamingService

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
info.bitrich.xchangestream.kraken.KrakenStreamingService
public class KrakenStreamingService extends info.bitrich.xchangestream.service.netty.JsonNettyStreamingService
Author:
makarid, pchertalev

  • Nested Class Summary

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

    info.bitrich.xchangestream.service.netty.NettyStreamingService.NettyWebSocketClientHandler, info.bitrich.xchangestream.service.netty.NettyStreamingService.Subscription

  • Field Summary

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

    objectMapper

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

    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
    KrakenStreamingService(KrakenStreamingExchange exchange, boolean isPrivate, String uri, int maxFramePayloadLength, Duration connectionTimeout, Duration retryDuration, int idleTimeoutSeconds, Supplier<KrakenWebsocketToken> authData)
     
    KrakenStreamingService(KrakenStreamingExchange exchange, boolean isPrivate, String uri, Supplier<KrakenWebsocketToken> authData)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.reactivex.rxjava3.core.Completable
    disconnect()
     
    protected String
    getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
     
    String
    getSubscribeMessage(String channelName, Object... args)
     
    String
    getUnsubscribeMessage(String channelName, Object... args)
     
    protected io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler
    getWebSocketClientExtensionHandler()
     
    protected info.bitrich.xchangestream.service.netty.WebSocketClientHandler
    getWebSocketClientHandler(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker, info.bitrich.xchangestream.service.netty.WebSocketClientHandler.WebSocketMessageHandler handler)
     
    protected void
    handleMessage(com.fasterxml.jackson.databind.JsonNode message)
     
    boolean
    processArrayMessageSeparately()
     
    void
    sendMessage(String message)
     
    io.reactivex.rxjava3.core.Observable<KrakenEvent>
    subscribeSystemChannel(KrakenEventType eventType)
     

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

    messageHandler, sendObjectMessage

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

    getChannel, getCustomHeaders, getSubscriptionUniqueId, handleChannelError, handleChannelMessage, handleError, handleIdle, isSocketOpen, openConnection, resubscribeChannels, 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

  • Constructor Details

  • Method Details

    • processArrayMessageSeparately

      public boolean processArrayMessageSeparately()
      Overrides:
      processArrayMessageSeparately in class info.bitrich.xchangestream.service.netty.JsonNettyStreamingService

    • getWebSocketClientExtensionHandler

      protected io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler getWebSocketClientExtensionHandler()
      Overrides:
      getWebSocketClientExtensionHandler in class info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

    • subscribeSystemChannel

      public io.reactivex.rxjava3.core.Observable<KrakenEvent> subscribeSystemChannel(KrakenEventType eventType)

    • disconnect

      public io.reactivex.rxjava3.core.Completable disconnect()
      Overrides:
      disconnect in class info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

    • handleMessage

      protected void handleMessage(com.fasterxml.jackson.databind.JsonNode message)
      Overrides:
      handleMessage in class info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

    • getChannelNameFromMessage

      protected String getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message) throws IOException
      Specified by:
      getChannelNameFromMessage in class info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
      Throws:
      IOException

    • getSubscribeMessage

      public String getSubscribeMessage(String channelName, Object... args) throws IOException
      Specified by:
      getSubscribeMessage in class info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
      Throws:
      IOException

    • getUnsubscribeMessage

      public String getUnsubscribeMessage(String channelName, Object... args) throws IOException
      Specified by:
      getUnsubscribeMessage in class info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
      Throws:
      IOException

    • sendMessage

      public void sendMessage(String message)
      Overrides:
      sendMessage in class info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

    • getWebSocketClientHandler

      protected info.bitrich.xchangestream.service.netty.WebSocketClientHandler getWebSocketClientHandler(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker, info.bitrich.xchangestream.service.netty.WebSocketClientHandler.WebSocketMessageHandler handler)
      Overrides:
      getWebSocketClientHandler in class info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>