Package info.bitrich.xchangestream.okex

Class OkexPrivateStreamingService

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.OkexPrivateStreamingService

public class OkexPrivateStreamingService
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 final String	CANCEL_ORDER
static final String	CHANGE_ORDER
static final String	PLACE_ORDER
static final String	USER_ORDER_CHANGES
static final String	USER_POSITION_CHANGES

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
OkexPrivateStreamingService(String privateApiUrl, ExchangeSpecification exchangeSpecification, OkexExchange okexExchange)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Completable	connect()
protected String	getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
String	getSubscribeMessage(String channelName, Object... args)
String	getSubscriptionUniqueId(String channelName, Object... args)
String	getUnsubscribeMessage(String channelName, Object... args)
void	login()
void	messageHandler(String message)	Handler that receives incoming messages.
void	pingPongDisconnectIfConnected()
void	resubscribeChannels()

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, getWebSocketClientExtensionHandler, getWebSocketClientHandler, handleChannelError, handleChannelMessage, handleError, handleIdle, handleMessage, isSocketOpen, openConnection, 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

USER_ORDER_CHANGES

public static final String USER_ORDER_CHANGES

See Also:

• Constant Field Values

USER_POSITION_CHANGES

public static final String USER_POSITION_CHANGES

See Also:

• Constant Field Values

PLACE_ORDER

public static final String PLACE_ORDER

See Also:

• Constant Field Values

CHANGE_ORDER

public static final String CHANGE_ORDER

See Also:

• Constant Field Values

CANCEL_ORDER

public static final String CANCEL_ORDER

See Also:

• Constant Field Values

Constructor Details

OkexPrivateStreamingService

public OkexPrivateStreamingService(String privateApiUrl,
 ExchangeSpecification exchangeSpecification,
 OkexExchange okexExchange)

Method Details

connect

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

Overrides:

connect in class ConnectableService

login

public void login()
           throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

pingPongDisconnectIfConnected

public void pingPongDisconnectIfConnected()

getSubscriptionUniqueId

public String getSubscriptionUniqueId(String channelName,
 Object... args)

Overrides:

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

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.

getChannelNameFromMessage

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

Specified by:

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

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

resubscribeChannels

public void resubscribeChannels()

Overrides:

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