Package info.bitrich.xchangestream.cexio
Class CexioStreamingRawService
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.cexio.CexioStreamingRawService
public class CexioStreamingRawService extends JsonNettyStreamingService
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static class
CexioStreamingRawService.AuthCompletable
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
AUTH
static String
CONNECTED
static String
ORDER
static String
ORDERBOOK
static String
ORDERBOOK_UPDATE
static String
PING
static String
PONG
static String
TRANSACTION
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 CexioStreamingRawService(String apiUrl)
-
Method Summary
Modifier and Type Method Description io.reactivex.Completable
connect()
protected String
getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
static CurrencyPair
GetCurrencyPairForChannelName(String channelName)
static String
GetOrderBookChannelForCurrencyPair(CurrencyPair currencyPair)
io.reactivex.Observable<Order>
getOrderData()
String
getSubscribeMessage(String channelName, Object... args)
io.reactivex.Observable<CexioWebSocketTransaction>
getTransactions()
String
getUnsubscribeMessage(String channelName, Object... args)
protected void
handleMessage(com.fasterxml.jackson.databind.JsonNode message)
void
messageHandler(String message)
Handler that receives incoming messages.void
setApiKey(String apiKey)
void
setApiSecret(String apiSecret)
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, 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
-
CONNECTED
- See Also:
- Constant Field Values
-
AUTH
- See Also:
- Constant Field Values
-
PING
- See Also:
- Constant Field Values
-
PONG
- See Also:
- Constant Field Values
-
ORDER
- See Also:
- Constant Field Values
-
TRANSACTION
- See Also:
- Constant Field Values
-
ORDERBOOK
- See Also:
- Constant Field Values
-
ORDERBOOK_UPDATE
- See Also:
- Constant Field Values
-
-
Constructor Details
-
CexioStreamingRawService
-
-
Method Details
-
GetOrderBookChannelForCurrencyPair
-
GetCurrencyPairForChannelName
-
getChannelNameFromMessage
protected String getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message) throws IOException- Specified by:
getChannelNameFromMessage
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
- Throws:
IOException
-
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
-
messageHandler
Description copied from class:NettyStreamingService
Handler that receives incoming messages.- Overrides:
messageHandler
in classJsonNettyStreamingService
- Parameters:
message
- Content of the message from the server.
-
connect
public io.reactivex.Completable connect()- Overrides:
connect
in classConnectableService
-
handleMessage
protected void handleMessage(com.fasterxml.jackson.databind.JsonNode message)- Overrides:
handleMessage
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
-
setApiKey
-
setApiSecret
-
getOrderData
-
getTransactions
-