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 final String	AUTH
static final String	CONNECTED
static final String	ORDER
static final String	ORDERBOOK
static final String	ORDERBOOK_UPDATE
static final String	PING
static final String	PONG
static final 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.rxjava3.core.Completable	connect()
protected String	getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
static CurrencyPair	GetCurrencyPairForChannelName(String channelName)
static String	GetOrderBookChannelForCurrencyPair(CurrencyPair currencyPair)
io.reactivex.rxjava3.core.Observable<Order>	getOrderData()
String	getSubscribeMessage(String channelName, Object... args)
io.reactivex.rxjava3.core.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

Methods inherited from class java.lang.Object

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

Field Details

CONNECTED

public static final String CONNECTED

See Also:

• Constant Field Values

AUTH

public static final String AUTH

See Also:

• Constant Field Values

PING

public static final String PING

See Also:

• Constant Field Values

PONG

public static final String PONG

See Also:

• Constant Field Values

ORDER

public static final String ORDER

See Also:

• Constant Field Values

TRANSACTION

public static final String TRANSACTION

See Also:

• Constant Field Values

ORDERBOOK

public static final String ORDERBOOK

See Also:

• Constant Field Values

ORDERBOOK_UPDATE

public static final String ORDERBOOK_UPDATE

See Also:

• Constant Field Values

Constructor Details

CexioStreamingRawService

public CexioStreamingRawService(String apiUrl)

Method Details

GetOrderBookChannelForCurrencyPair

public static String GetOrderBookChannelForCurrencyPair(CurrencyPair currencyPair)

GetCurrencyPairForChannelName

public static CurrencyPair GetCurrencyPairForChannelName(String channelName)

getChannelNameFromMessage

protected String getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
                                    throws IOException

Specified by:

getChannelNameFromMessage in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

Throws:

IOException

getSubscribeMessage

public String getSubscribeMessage(String channelName,
 Object... args)
                           throws IOException

Specified by:

getSubscribeMessage in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

Throws:

IOException

getUnsubscribeMessage

public String getUnsubscribeMessage(String channelName,
 Object... args)
                             throws IOException

Specified by:

getUnsubscribeMessage in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

Throws:

IOException

messageHandler

public void messageHandler(String message)

Description copied from class: NettyStreamingService

Handler that receives incoming messages.

Overrides:

messageHandler in class JsonNettyStreamingService

Parameters:

message - Content of the message from the server.

connect

public io.reactivex.rxjava3.core.Completable connect()

Overrides:

connect in class ConnectableService

handleMessage

protected void handleMessage(com.fasterxml.jackson.databind.JsonNode message)

Overrides:

handleMessage in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

setApiKey

public void setApiKey(String apiKey)

setApiSecret

public void setApiSecret(String apiSecret)

getOrderData

public io.reactivex.rxjava3.core.Observable<Order> getOrderData()

getTransactions

public io.reactivex.rxjava3.core.Observable<CexioWebSocketTransaction> getTransactions()