Class CoinmateStreamingExchange
- java.lang.Object
-
- org.knowm.xchange.BaseExchange
-
- org.knowm.xchange.coinmate.CoinmateExchange
-
- info.bitrich.xchangestream.coinmate.CoinmateStreamingExchange
-
- All Implemented Interfaces:
StreamingExchange
,Exchange
public class CoinmateStreamingExchange extends CoinmateExchange implements StreamingExchange
-
-
Field Summary
-
Fields inherited from class org.knowm.xchange.BaseExchange
accountService, exchangeMetaData, exchangeSpecification, logger, marketDataService, tradeService
-
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, USE_SANDBOX
-
-
Constructor Summary
Constructors Constructor Description CoinmateStreamingExchange()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.reactivex.Completable
connect(ProductSubscription... args)
Connects to the WebSocket API of the exchange.io.reactivex.Completable
disconnect()
Disconnect from the WebSocket API.StreamingAccountService
getStreamingAccountService()
Returns service that can be used to access streaming account data.StreamingMarketDataService
getStreamingMarketDataService()
Returns service that can be used to access streaming market data.StreamingTradeService
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.void
useCompressedMessages(boolean compressedMessages)
Set whether or not to enable compression handler.-
Methods inherited from class org.knowm.xchange.coinmate.CoinmateExchange
getDefaultExchangeSpecification, getNonceFactory, remoteInit
-
Methods inherited from class org.knowm.xchange.BaseExchange
applySpecification, getAccountService, getExchangeMetaData, getExchangeSpecification, getExchangeSymbols, 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, getExchangeSymbols, getMarketDataService, getNonceFactory, getResilienceRegistries, getTradeService, remoteInit
-
Methods inherited from interface info.bitrich.xchangestream.core.StreamingExchange
applyStreamingSpecification, connectionIdle, connectionStateObservable, connectionSuccess, disconnectObservable, messageDelay, reconnectFailure, resubscribeChannels
-
-
-
-
Method Detail
-
initServices
protected void initServices()
- Overrides:
initServices
in classCoinmateExchange
-
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 interfaceStreamingExchange
- 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 interfaceStreamingExchange
- Returns:
Completable
that completes upon successful disconnect.
-
getStreamingMarketDataService
public StreamingMarketDataService getStreamingMarketDataService()
Description copied from interface:StreamingExchange
Returns service that can be used to access streaming market data.- Specified by:
getStreamingMarketDataService
in interfaceStreamingExchange
-
getStreamingTradeService
public StreamingTradeService getStreamingTradeService()
Description copied from interface:StreamingExchange
Returns service that can be used to access streaming trade data.- Specified by:
getStreamingTradeService
in interfaceStreamingExchange
-
getStreamingAccountService
public StreamingAccountService getStreamingAccountService()
Description copied from interface:StreamingExchange
Returns service that can be used to access streaming account data.- Specified by:
getStreamingAccountService
in interfaceStreamingExchange
-
isAlive
public boolean isAlive()
Description copied from interface:StreamingExchange
Checks whether connection to the exchange is alive.- Specified by:
isAlive
in interfaceStreamingExchange
- Returns:
- true if connection is open, otherwise false.
-
useCompressedMessages
public void useCompressedMessages(boolean compressedMessages)
Description copied from interface:StreamingExchange
Set whether or not to enable compression handler.- Specified by:
useCompressedMessages
in interfaceStreamingExchange
- Parameters:
compressedMessages
- Defaults to false
-
-