Package info.bitrich.xchangestream.bybit

Class BybitUserTradeStreamingService

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.bybit.BybitUserTradeStreamingService

public class BybitUserTradeStreamingService
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	BATCH_ORDER_CANCEL
static final String	BATCH_ORDER_CHANGE
static final String	BATCH_ORDER_CREATE
static final String	ORDER_CANCEL
static final String	ORDER_CHANGE
static final String	ORDER_CREATE

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
BybitUserTradeStreamingService(String apiUrl, ExchangeSpecification spec)

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)
protected io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler	getWebSocketClientExtensionHandler()
void	messageHandler(String message)	Handler that receives incoming messages.
void	pingPongDisconnectIfConnected()
void	sendMessage(String message)

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

ORDER_CREATE

public static final String ORDER_CREATE

See Also:

• Constant Field Values

BATCH_ORDER_CREATE

public static final String BATCH_ORDER_CREATE

See Also:

• Constant Field Values

ORDER_CHANGE

public static final String ORDER_CHANGE

See Also:

• Constant Field Values

BATCH_ORDER_CHANGE

public static final String BATCH_ORDER_CHANGE

See Also:

• Constant Field Values

ORDER_CANCEL

public static final String ORDER_CANCEL

See Also:

• Constant Field Values

BATCH_ORDER_CANCEL

public static final String BATCH_ORDER_CANCEL

See Also:

• Constant Field Values

Constructor Details

BybitUserTradeStreamingService

public BybitUserTradeStreamingService(String apiUrl,
 ExchangeSpecification spec)

Method Details

connect

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

Overrides:

connect in class ConnectableService

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.

getWebSocketClientExtensionHandler

protected io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler getWebSocketClientExtensionHandler()

Overrides:

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

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

getSubscriptionUniqueId

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

Overrides:

getSubscriptionUniqueId 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

pingPongDisconnectIfConnected

public void pingPongDisconnectIfConnected()

sendMessage

public void sendMessage(String message)

Overrides:

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