Package info.bitrich.xchangestream.okex
Class OkexStreamingService
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.okex.OkexStreamingService
public class OkexStreamingService extends JsonNettyStreamingService
-
Nested Class Summary
Nested classes/interfaces inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService
NettyStreamingService.NettyWebSocketClientHandler, NettyStreamingService.Subscription
-
Field Summary
Fields Modifier and Type Field Description static String
FUNDING_RATE
static String
ORDERBOOK
static String
ORDERBOOK5
static String
TICKERS
static String
TRADES
static String
USERTRADES
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 OkexStreamingService(String apiUrl, ExchangeSpecification exchangeSpecification)
-
Method Summary
Modifier and Type Method Description io.reactivex.Completable
connect()
protected String
getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
String
getSubscribeMessage(String channelName, Object... args)
String
getUnsubscribeMessage(String channelName, Object... args)
void
login()
void
messageHandler(String message)
Handler that receives incoming messages.Methods inherited from class info.bitrich.xchangestream.service.netty.JsonNettyStreamingService
processArrayMessageSeparately, sendObjectMessage
Methods inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService
disconnect, getChannel, getCustomHeaders, getSubscriptionUniqueId, getWebSocketClientExtensionHandler, getWebSocketClientHandler, handleChannelError, handleChannelMessage, handleError, handleIdle, handleMessage, 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
-
Field Details
-
TRADES
- See Also:
- Constant Field Values
-
ORDERBOOK
- See Also:
- Constant Field Values
-
ORDERBOOK5
- See Also:
- Constant Field Values
-
FUNDING_RATE
- See Also:
- Constant Field Values
-
TICKERS
- See Also:
- Constant Field Values
-
USERTRADES
- See Also:
- Constant Field Values
-
-
Constructor Details
-
OkexStreamingService
-
-
Method Details
-
connect
public io.reactivex.Completable connect()- Overrides:
connect
in classConnectableService
-
login
public void login() throws com.fasterxml.jackson.core.JsonProcessingException- Throws:
com.fasterxml.jackson.core.JsonProcessingException
-
messageHandler
Description copied from class:NettyStreamingService
Handler that receives incoming messages.- Overrides:
messageHandler
in classJsonNettyStreamingService
- Parameters:
message
- Content of the message from the server.
-
getChannelNameFromMessage
- Specified by:
getChannelNameFromMessage
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
-
getSubscribeMessage
- Specified by:
getSubscribeMessage
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
- Throws:
IOException
-
getUnsubscribeMessage
- Specified by:
getUnsubscribeMessage
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
- Throws:
IOException
-