Package info.bitrich.xchangestream.binance

Class BinanceUserDataSpotStreamingService

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.binance.BinanceUserDataSpotStreamingService

public class BinanceUserDataSpotStreamingService
extends JsonNettyStreamingService

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
BinanceUserDataSpotStreamingService(String apiUrl, String apiKey, String privateKey, ExchangeSpecification exchangeSpecification)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Completable	connect()
io.reactivex.rxjava3.core.Completable	disconnect()
protected String	getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
String	getSubscribeMessage(String channelName, Object... args)
String	getSubscriptionUniqueId(String channelName, Object... args)
String	getUnsubscribeMessage(String channelName, Object... args)
protected void	handleMessage(com.fasterxml.jackson.databind.JsonNode message)
void	login()
void	messageHandler(String message)	Handler that receives incoming messages.
String	signPayload(String payload)
io.reactivex.rxjava3.core.Observable<com.fasterxml.jackson.databind.JsonNode>	subscribeChannel(BaseBinanceWebSocketTransaction.BinanceWebSocketTypes eventType)

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

processArrayMessageSeparately, sendObjectMessage

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

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

setBeforeConnectionHandler

Methods inherited from class java.lang.Object

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

Constructor Details

BinanceUserDataSpotStreamingService

public BinanceUserDataSpotStreamingService(String apiUrl,
 String apiKey,
 String privateKey,
 ExchangeSpecification exchangeSpecification)

Method Details

connect

public io.reactivex.rxjava3.core.Completable connect()

Overrides:

connect in class ConnectableService

login

public void login()

getSubscriptionUniqueId

public String getSubscriptionUniqueId(String channelName,
 Object... args)

Overrides:

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

getSubscribeMessage

public String getSubscribeMessage(String channelName,
 Object... args)
                           throws IOException

Specified by:

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

Throws:

IOException

signPayload

public String signPayload(String payload)
                   throws Exception

Throws:

Exception

disconnect

public io.reactivex.rxjava3.core.Completable disconnect()

Overrides:

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

messageHandler

public void messageHandler(String message)

Description copied from class: NettyStreamingService

Handler that receives incoming messages.

Overrides:

messageHandler in class JsonNettyStreamingService

Parameters:

message - Content of the message from the server.

handleMessage

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

Overrides:

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

subscribeChannel

public io.reactivex.rxjava3.core.Observable<com.fasterxml.jackson.databind.JsonNode> subscribeChannel(BaseBinanceWebSocketTransaction.BinanceWebSocketTypes eventType)

getChannelNameFromMessage

protected String getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)

Specified by:

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

getUnsubscribeMessage

public String getUnsubscribeMessage(String channelName,
 Object... args)

Specified by:

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