Package info.bitrich.xchangestream.bitget

Class BitgetStreamingService

java.lang.Object

info.bitrich.xchangestream.service.ConnectableService

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

info.bitrich.xchangestream.bitget.BitgetStreamingService

Direct Known Subclasses:

BitgetPrivateStreamingService

public class BitgetStreamingService
extends NettyStreamingService<BitgetWsNotification>

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
protected final com.fasterxml.jackson.databind.ObjectMapper	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
BitgetStreamingService(String apiUri)

Method Summary

Modifier and Type	Method	Description
protected String	getChannelNameFromMessage(BitgetWsNotification message)
String	getSubscribeMessage(String channelName, Object... args)
String	getSubscriptionUniqueId(String channelName, Object... args)
String	getUnsubscribeMessage(String channelName, Object... args)
protected void	handleChannelMessage(String channel, BitgetWsNotification message)
protected void	handleMessage(BitgetWsNotification message)
void	messageHandler(String message)	Handler that receives incoming messages.

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

disconnect, getChannel, getCustomHeaders, getWebSocketClientExtensionHandler, getWebSocketClientHandler, handleChannelError, 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

connect, setBeforeConnectionHandler

Methods inherited from class java.lang.Object

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

Field Details

objectMapper

protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Details

BitgetStreamingService

public BitgetStreamingService(String apiUri)

Method Details

getChannelNameFromMessage

protected String getChannelNameFromMessage(BitgetWsNotification message)

Specified by:

getChannelNameFromMessage in class NettyStreamingService<BitgetWsNotification>

getSubscribeMessage

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

Specified by:

getSubscribeMessage in class NettyStreamingService<BitgetWsNotification>

Parameters:

channelName - ignored

args - [ChannelType, MarketType, Instrument/null]

Returns:

message to be sent for subscribing

Throws:

IOException

See Also:

• BitgetStreamingAdapters.toSubscriptionId(info.bitrich.xchangestream.bitget.dto.common.BitgetChannel)

getUnsubscribeMessage

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

Specified by:

getUnsubscribeMessage in class NettyStreamingService<BitgetWsNotification>

Parameters:

channelName - ignored

args - [ChannelType, MarketType, Instrument/null]

Returns:

message to be sent for unsubscribing

Throws:

IOException

See Also:

• BitgetStreamingAdapters.toSubscriptionId(info.bitrich.xchangestream.bitget.dto.common.BitgetChannel)

handleMessage

protected void handleMessage(BitgetWsNotification message)

Overrides:

handleMessage in class NettyStreamingService<BitgetWsNotification>

handleChannelMessage

protected void handleChannelMessage(String channel,
 BitgetWsNotification message)

Overrides:

handleChannelMessage in class NettyStreamingService<BitgetWsNotification>

getSubscriptionUniqueId

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

Overrides:

getSubscriptionUniqueId in class NettyStreamingService<BitgetWsNotification>

Parameters:

channelName - name of channel

args - array with [MarketType, Instrument, ...]

Returns:

subscription id in form of "marketType_channelName_instrument1_instrumentX"

messageHandler

public void messageHandler(String message)

Description copied from class: NettyStreamingService

Handler that receives incoming messages.

Specified by:

messageHandler in class NettyStreamingService<BitgetWsNotification>

Parameters:

message - Content of the message from the server.