Package info.bitrich.xchangestream.ftx
Class FtxStreamingService
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.ftx.FtxStreamingService
public class FtxStreamingService extends JsonNettyStreamingService
-
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.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 FtxStreamingService(String apiUrl)
FtxStreamingService(String apiUrl, Supplier<FtxWebsocketCredential> authData)
-
Method Summary
Modifier and Type Method Description protected String
getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
String
getSubscribeMessage(String channelName, Object... args)
String
getUnsubscribeMessage(String channelName, Object... args)
protected io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler
getWebSocketClientExtensionHandler()
protected void
handleMessage(com.fasterxml.jackson.databind.JsonNode message)
void
resubscribeChannels()
Methods inherited from class info.bitrich.xchangestream.service.netty.JsonNettyStreamingService
messageHandler, processArrayMessageSeparately, sendObjectMessage
Methods inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService
disconnect, getChannel, getCustomHeaders, getSubscriptionUniqueId, getWebSocketClientHandler, handleChannelError, handleChannelMessage, handleError, handleIdle, 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
connect, setBeforeConnectionHandler
-
Constructor Details
-
FtxStreamingService
-
FtxStreamingService
-
-
Method Details
-
getWebSocketClientExtensionHandler
protected io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler getWebSocketClientExtensionHandler()- Overrides:
getWebSocketClientExtensionHandler
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
-
handleMessage
protected void handleMessage(com.fasterxml.jackson.databind.JsonNode message)- Overrides:
handleMessage
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
-
getChannelNameFromMessage
- Specified by:
getChannelNameFromMessage
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
-
getSubscribeMessage
- Specified by:
getSubscribeMessage
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
- Throws:
IOException
-
getUnsubscribeMessage
- Specified by:
getUnsubscribeMessage
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
- Throws:
IOException
-
resubscribeChannels
public void resubscribeChannels()- Overrides:
resubscribeChannels
in classNettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
-