Package info.bitrich.xchangestream.binance

Class BinanceStreamingExchange

java.lang.Object

org.knowm.xchange.BaseExchange

org.knowm.xchange.binance.BinanceExchange

info.bitrich.xchangestream.binance.BinanceStreamingExchange

All Implemented Interfaces:

StreamingExchange, Exchange

Direct Known Subclasses:

BinanceFutureStreamingExchange, BinanceUsStreamingExchange

public class BinanceStreamingExchange
extends BinanceExchange
implements StreamingExchange

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FETCH_ORDER_BOOK_LIMIT
static final String	USE_HIGHER_UPDATE_FREQUENCY
static final String	USE_REALTIME_BOOK_TICKER

Fields inherited from class org.knowm.xchange.binance.BinanceExchange

FUTURES_URL, INVERSE_FUTURES_URL, PORTFOLIO_MARGIN_URL, RESILIENCE_REGISTRIES, SANDBOX_FUTURES_URL, SPECIFIC_PARAM_FUTURES_ENABLED, SPECIFIC_PARAM_PORTFOLIO_MARGIN_ENABLED, SPECIFIC_PARAM_USE_FUTURES_SANDBOX, SPECIFIC_PARAM_USE_SANDBOX, timestampFactory

Fields inherited from class org.knowm.xchange.BaseExchange

accountService, exchangeMetaData, exchangeSpecification, logger, marketDataService, tradeService

Fields inherited from interface org.knowm.xchange.Exchange

USE_SANDBOX

Fields inherited from interface info.bitrich.xchangestream.core.StreamingExchange

ACCEPT_ALL_CERITICATES, AUTO_RECONNECT, ENABLE_LOGGING_HANDLER, L3_ORDERBOOK, SOCKS_PROXY_HOST, SOCKS_PROXY_PORT

Constructor Summary

Constructors

Constructor	Description
BinanceStreamingExchange()

Method Summary

Modifier and Type	Method	Description
String	buildSubscriptionStreams(ProductSubscription subscription)
io.reactivex.Completable	connect(KlineSubscription klineSubscription, ProductSubscription... args)
io.reactivex.Completable	connect(ProductSubscription... args)	Binance streaming API expects connections to multiple channels to be defined at connection time.
io.reactivex.Observable<ConnectionStateModel.State>	connectionStateObservable()	Observable for connectionState.
io.reactivex.Observable<Object>	connectionSuccess()	Observable for connection success event.
protected BinanceStreamingService	createStreamingService(ProductSubscription subscription, KlineSubscription klineSubscription)
void	disableLiveSubscription()
io.reactivex.Completable	disconnect()	Disconnect from the WebSocket API.
void	enableLiveSubscription()
BinanceStreamingAccountService	getStreamingAccountService()	Returns service that can be used to access streaming account data.
protected String	getStreamingBaseUri()
BinanceStreamingMarketDataService	getStreamingMarketDataService()	Returns service that can be used to access streaming market data.
BinanceStreamingTradeService	getStreamingTradeService()	Returns service that can be used to access streaming trade data.
protected void	initServices()
boolean	isAlive()	Checks whether connection to the exchange is alive.
io.reactivex.Observable<Throwable>	reconnectFailure()	Observable for reconnection failure event.
void	setChannelInactiveHandler(WebSocketClientHandler.WebSocketMessageHandler channelInactiveHandler)	Enables the user to listen on channel inactive events and react appropriately.
void	useCompressedMessages(boolean compressedMessages)	Set whether or not to enable compression handler.

Methods inherited from class org.knowm.xchange.binance.BinanceExchange

applySpecification, getDefaultExchangeSpecification, getNonceFactory, getResilienceRegistries, getTimestampFactory, isAuthenticated, isFuturesEnabled, isFuturesSandbox, isPortfolioMarginEnabled, remoteInit, resetResilienceRegistries, usingSandbox

Methods inherited from class org.knowm.xchange.BaseExchange

getAccountService, getExchangeInstruments, getExchangeMetaData, getExchangeSpecification, getMarketDataService, getMetaDataFileName, getTradeService, loadExchangeMetaData, loadMetaData, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.knowm.xchange.Exchange

applySpecification, getAccountService, getDefaultExchangeSpecification, getExchangeInstruments, getExchangeMetaData, getExchangeSpecification, getMarketDataService, getNonceFactory, getResilienceRegistries, getTradeService, remoteInit

Methods inherited from interface info.bitrich.xchangestream.core.StreamingExchange

applyStreamingSpecification, connectionIdle, disconnectObservable, messageDelay, resubscribeChannels

Field Details

USE_HIGHER_UPDATE_FREQUENCY

public static final String USE_HIGHER_UPDATE_FREQUENCY

See Also:

• Constant Field Values

USE_REALTIME_BOOK_TICKER

public static final String USE_REALTIME_BOOK_TICKER

See Also:

• Constant Field Values

FETCH_ORDER_BOOK_LIMIT

public static final String FETCH_ORDER_BOOK_LIMIT

See Also:

• Constant Field Values

Constructor Details

BinanceStreamingExchange

public BinanceStreamingExchange()

Method Details

initServices

protected void initServices()

Overrides:

initServices in class BinanceExchange

connect

public io.reactivex.Completable connect(KlineSubscription klineSubscription,
 ProductSubscription... args)

connect

public io.reactivex.Completable connect(ProductSubscription... args)

Binance streaming API expects connections to multiple channels to be defined at connection time. To define the channels for this connection pass a `ProductSubscription` in at connection time.

Specified by:

connect in interface StreamingExchange

Parameters:

args - A single `ProductSubscription` to define the subscriptions required to be available during this connection.

Returns:

A completable which fulfils once connection is complete.

disconnect

public io.reactivex.Completable disconnect()

Description copied from interface: StreamingExchange

Disconnect from the WebSocket API.

Specified by:

disconnect in interface StreamingExchange

Returns:

Completable that completes upon successful disconnect.

isAlive

public boolean isAlive()

Description copied from interface: StreamingExchange

Checks whether connection to the exchange is alive.

Specified by:

isAlive in interface StreamingExchange

Returns:

true if connection is open, otherwise false.

reconnectFailure

public io.reactivex.Observable<Throwable> reconnectFailure()

Description copied from interface: StreamingExchange

Observable for reconnection failure event. When this happens, it usually indicates that the server or the network is down.

Specified by:

reconnectFailure in interface StreamingExchange

Returns:

Observable with the exception during reconnection.

connectionSuccess

public io.reactivex.Observable<Object> connectionSuccess()

Description copied from interface: StreamingExchange

Observable for connection success event. When this happens, it usually indicates that the server or the network is down.

Specified by:

connectionSuccess in interface StreamingExchange

Returns:

Observable

connectionStateObservable

public io.reactivex.Observable<ConnectionStateModel.State> connectionStateObservable()

Description copied from interface: StreamingExchange

Observable for connectionState. designed to replaces connectionSuccess reconnectFailure disconnectObservable

Specified by:

connectionStateObservable in interface StreamingExchange

Returns:

Observable

getStreamingMarketDataService

public BinanceStreamingMarketDataService getStreamingMarketDataService()

Description copied from interface: StreamingExchange

Returns service that can be used to access streaming market data.

Specified by:

getStreamingMarketDataService in interface StreamingExchange

getStreamingAccountService

public BinanceStreamingAccountService getStreamingAccountService()

Description copied from interface: StreamingExchange

Returns service that can be used to access streaming account data.

Specified by:

getStreamingAccountService in interface StreamingExchange

getStreamingTradeService

public BinanceStreamingTradeService getStreamingTradeService()

Description copied from interface: StreamingExchange

Returns service that can be used to access streaming trade data.

Specified by:

getStreamingTradeService in interface StreamingExchange

createStreamingService

protected BinanceStreamingService createStreamingService(ProductSubscription subscription,
 KlineSubscription klineSubscription)

getStreamingBaseUri

protected String getStreamingBaseUri()

buildSubscriptionStreams

public String buildSubscriptionStreams(ProductSubscription subscription)

useCompressedMessages

public void useCompressedMessages(boolean compressedMessages)

Description copied from interface: StreamingExchange

Set whether or not to enable compression handler.

Specified by:

useCompressedMessages in interface StreamingExchange

Parameters:

compressedMessages - Defaults to false

enableLiveSubscription

public void enableLiveSubscription()

disableLiveSubscription

public void disableLiveSubscription()

setChannelInactiveHandler

public void setChannelInactiveHandler(WebSocketClientHandler.WebSocketMessageHandler channelInactiveHandler)

Enables the user to listen on channel inactive events and react appropriately.

Parameters:

channelInactiveHandler - a WebSocketMessageHandler instance.