Package info.bitrich.xchangestream.gateio

Class GateioStreamingService

java.lang.Object

info.bitrich.xchangestream.service.ConnectableService

info.bitrich.xchangestream.service.netty.NettyStreamingService<GateioWsNotification>

info.bitrich.xchangestream.gateio.GateioStreamingService

public class GateioStreamingService
extends NettyStreamingService<GateioWsNotification>

Nested Class Summary

Nested classes/interfaces inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService

NettyStreamingService.NettyWebSocketClientHandler, NettyStreamingService.Subscription

Field Summary

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
GateioStreamingService(String apiUri, String apiKey, String apiSecret)

Method Summary

Modifier and Type	Method	Description
protected String	getChannelNameFromMessage(GateioWsNotification message)
String	getSubscribeMessage(String uniqueChannelName, Object... args)	Returns a JSON String containing the subscription message.
String	getUnsubscribeMessage(String uniqueChannelName, Object... args)	Returns a JSON String containing the unsubscribe message.
protected io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler	getWebSocketClientExtensionHandler()
protected void	handleChannelMessage(String channel, GateioWsNotification message)
void	messageHandler(String message)	Handler that receives incoming messages.
io.reactivex.rxjava3.core.Observable<GateioWsNotification>	subscribeChannel(String channelName, Object... args)

Methods inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService

disconnect, getChannel, getCustomHeaders, getSubscriptionUniqueId, getWebSocketClientHandler, handleChannelError, handleError, handleIdle, handleMessage, isSocketOpen, openConnection, resubscribeChannels, sendMessage, setAcceptAllCertificates, setAutoReconnect, setEnableLoggingHandler, setLoggingHandlerLevel, setSocksProxyHost, setSocksProxyPort, subscribeConnectionState, subscribeConnectionSuccess, subscribeDisconnect, subscribeIdle, subscribeReconnectFailure, useCompressedMessages

Methods inherited from class info.bitrich.xchangestream.service.ConnectableService

connect, setBeforeConnectionHandler

Methods inherited from class java.lang.Object

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

Constructor Details

GateioStreamingService

public GateioStreamingService(String apiUri,
 String apiKey,
 String apiSecret)

Method Details

getChannelNameFromMessage

protected String getChannelNameFromMessage(GateioWsNotification message)

Specified by:

getChannelNameFromMessage in class NettyStreamingService<GateioWsNotification>

subscribeChannel

public io.reactivex.rxjava3.core.Observable<GateioWsNotification> subscribeChannel(String channelName,
 Object... args)

Overrides:

subscribeChannel in class NettyStreamingService<GateioWsNotification>

getSubscribeMessage

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

Returns a JSON String containing the subscription message.

Specified by:

getSubscribeMessage in class NettyStreamingService<GateioWsNotification>

Parameters:

uniqueChannelName - e.g. spot.order_book-BTC/USDT

args - CurrencyPair to subscribe and additional channel-specific arguments

Returns:

subscription message

Throws:

IOException

getWebSocketClientExtensionHandler

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

Overrides:

getWebSocketClientExtensionHandler in class NettyStreamingService<GateioWsNotification>

getUnsubscribeMessage

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

Returns a JSON String containing the unsubscribe message.

Specified by:

getUnsubscribeMessage in class NettyStreamingService<GateioWsNotification>

Parameters:

uniqueChannelName - e.g. spot.order_book-BTC/USDT

args - CurrencyPair to subscribe and additional channel-specific arguments

Returns:

unsubscribe message

Throws:

IOException

messageHandler

public void messageHandler(String message)

Description copied from class: NettyStreamingService

Handler that receives incoming messages.

Specified by:

messageHandler in class NettyStreamingService<GateioWsNotification>

Parameters:

message - Content of the message from the server.

handleChannelMessage

protected void handleChannelMessage(String channel,
 GateioWsNotification message)

Overrides:

handleChannelMessage in class NettyStreamingService<GateioWsNotification>