Package info.bitrich.xchangestream.cryptocom

Class CryptoComPrivateStreamingService

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.cryptocom.CryptoComStreamingService

info.bitrich.xchangestream.cryptocom.CryptoComPrivateStreamingService

public class CryptoComPrivateStreamingService
extends CryptoComStreamingService

The Crypto.com Exchange v1 user WebSocket feed requires signing in with public/auth immediately after connecting, before any user.* channel can be subscribed. Following the same connect -> authenticate -> (re)subscribe sequence used for reconnects, resubscribeChannels() - which the framework calls right after every successful connection - is overridden to send the login message instead of resubscribing; channels are (re)subscribed once the auth confirmation arrives, see handleMessage(JsonNode).

Nested Class Summary

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

NettyStreamingService.NettyWebSocketClientHandler, 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

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
CryptoComPrivateStreamingService(String apiUrl, String apiKey, String apiSecret)

Method Summary

Modifier and Type	Method	Description
protected void	handleMessage(com.fasterxml.jackson.databind.JsonNode message)
void	resubscribeChannels()

Methods inherited from class info.bitrich.xchangestream.cryptocom.CryptoComStreamingService

extractData, getChannelNameFromMessage, getSubscribeMessage, getUnsubscribeMessage, nextRequestId

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

messageHandler, processArrayMessageSeparately, sendObjectMessage

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

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

Constructor Details

CryptoComPrivateStreamingService

public CryptoComPrivateStreamingService(String apiUrl,
 String apiKey,
 String apiSecret)

Method Details

resubscribeChannels

public void resubscribeChannels()

Overrides:

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

handleMessage

protected void handleMessage(com.fasterxml.jackson.databind.JsonNode message)

Overrides:

handleMessage in class CryptoComStreamingService