Package info.bitrich.xchangestream.bitfinex

Class BitfinexStreamingService

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.bitfinex.BitfinexStreamingService

public class BitfinexStreamingService
extends JsonNettyStreamingService

Created by Lukas Zaoralek on 7.11.17.

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
BitfinexStreamingService(String apiUrl, si.mazi.rescu.SynchronizedValueFactory<Long> nonceFactory)
BitfinexStreamingService(String apiUrl, si.mazi.rescu.SynchronizedValueFactory<Long> nonceFactory, int maxFramePayloadLength, Duration connectionTimeout, Duration retryDuration, int idleTimeoutSeconds)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Completable	connect()
io.reactivex.rxjava3.core.Completable	disconnect()
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()
protected void	handleMessage(com.fasterxml.jackson.databind.JsonNode message)
boolean	processArrayMessageSeparately()

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

messageHandler, sendObjectMessage

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

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

setBeforeConnectionHandler

Methods inherited from class java.lang.Object

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

Constructor Details

BitfinexStreamingService

public BitfinexStreamingService(String apiUrl,
 si.mazi.rescu.SynchronizedValueFactory<Long> nonceFactory)

BitfinexStreamingService

public BitfinexStreamingService(String apiUrl,
 si.mazi.rescu.SynchronizedValueFactory<Long> nonceFactory,
 int maxFramePayloadLength,
 Duration connectionTimeout,
 Duration retryDuration,
 int idleTimeoutSeconds)

Method Details

connect

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

Overrides:

connect in class ConnectableService

disconnect

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

Overrides:

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

getWebSocketClientExtensionHandler

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

Overrides:

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

processArrayMessageSeparately

public boolean processArrayMessageSeparately()

Overrides:

processArrayMessageSeparately in class JsonNettyStreamingService

handleMessage

protected void handleMessage(com.fasterxml.jackson.databind.JsonNode message)

Overrides:

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

getSubscriptionUniqueId

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

Overrides:

getSubscriptionUniqueId 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

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