Package info.bitrich.xchangestream.bitfinex

Class BitfinexStreamingExchange

java.lang.Object

org.knowm.xchange.BaseExchange

org.knowm.xchange.bitfinex.BitfinexExchange

info.bitrich.xchangestream.bitfinex.BitfinexStreamingExchange

All Implemented Interfaces:

StreamingExchange, Exchange

public class BitfinexStreamingExchange
extends BitfinexExchange
implements StreamingExchange

Created by Lukas Zaoralek on 7.11.17.

Field Summary

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
BitfinexStreamingExchange()

Method Summary

Modifier and Type	Method	Description
io.reactivex.Completable	connect(ProductSubscription... args)	Connects to the WebSocket API of the exchange.
io.reactivex.Observable<Object>	connectionIdle()
io.reactivex.Observable<ConnectionStateModel.State>	connectionStateObservable()	Observable for connectionState.
io.reactivex.Observable<Object>	connectionSuccess()	Observable for connection success event.
io.reactivex.Completable	disconnect()	Disconnect from the WebSocket API.
ExchangeSpecification	getDefaultExchangeSpecification()
BitfinexStreamingAccountService	getStreamingAccountService()	Returns service that can be used to access streaming account data.
BitfinexStreamingMarketDataService	getStreamingMarketDataService()	Returns service that can be used to access streaming market data.
BitfinexStreamingTradeService	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.
boolean	isAuthenticatedAlive()
io.reactivex.Observable<Throwable>	reconnectFailure()	Observable for reconnection failure event.
void	useCompressedMessages(boolean compressedMessages)	Set whether or not to enable compression handler.

Methods inherited from class org.knowm.xchange.bitfinex.BitfinexExchange

getNonceFactory, getResilienceRegistries, remoteInit

Methods inherited from class org.knowm.xchange.BaseExchange

applySpecification, 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, getExchangeInstruments, getExchangeMetaData, getExchangeSpecification, getMarketDataService, getNonceFactory, getResilienceRegistries, getTradeService, remoteInit

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

applyStreamingSpecification, disconnectObservable, messageDelay, resubscribeChannels

Constructor Details

BitfinexStreamingExchange

public BitfinexStreamingExchange()

Method Details

initServices

protected void initServices()

Overrides:

initServices in class BitfinexExchange

connect

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

Description copied from interface: StreamingExchange

Connects to the WebSocket API of the exchange.

Specified by:

connect in interface StreamingExchange

Parameters:

args - Product subscription is used only in certain exchanges where you need to specify subscriptions during the connect phase.

Returns:

Completable that completes upon successful connection.

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

connectionIdle

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

Specified by:

connectionIdle in interface StreamingExchange

getDefaultExchangeSpecification

public ExchangeSpecification getDefaultExchangeSpecification()

Specified by:

getDefaultExchangeSpecification in interface Exchange

Overrides:

getDefaultExchangeSpecification in class BitfinexExchange

Returns:

A default ExchangeSpecification to use during the creation process if one is not supplied

getStreamingMarketDataService

public BitfinexStreamingMarketDataService 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 BitfinexStreamingAccountService 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 BitfinexStreamingTradeService getStreamingTradeService()

Description copied from interface: StreamingExchange

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

Specified by:

getStreamingTradeService in interface StreamingExchange

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

isAuthenticatedAlive

public boolean isAuthenticatedAlive()