Package info.bitrich.xchangestream.poloniex2

Class PoloniexStreamingService

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.poloniex2.PoloniexStreamingService

public class PoloniexStreamingService
extends JsonNettyStreamingService

Created by Lukas Zaoralek on 10.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
PoloniexStreamingService(String apiUrl)

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 void	handleMessage(com.fasterxml.jackson.databind.JsonNode message)
boolean	processArrayMessageSeparately()
io.reactivex.rxjava3.core.Observable<com.fasterxml.jackson.databind.JsonNode>	subscribeChannel(String channelName, Object... args)
io.reactivex.rxjava3.core.Observable<List<PoloniexWebSocketEvent>>	subscribeCurrencyPairChannel(CurrencyPair currencyPair)

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

messageHandler, sendObjectMessage

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

disconnect, getChannel, getCustomHeaders, getSubscriptionUniqueId, getWebSocketClientExtensionHandler, getWebSocketClientHandler, handleChannelError, handleChannelMessage, handleError, handleIdle, 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

PoloniexStreamingService

public PoloniexStreamingService(String apiUrl)

Method Details

handleMessage

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

Overrides:

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

processArrayMessageSeparately

public boolean processArrayMessageSeparately()

Overrides:

processArrayMessageSeparately in class JsonNettyStreamingService

subscribeChannel

public io.reactivex.rxjava3.core.Observable<com.fasterxml.jackson.databind.JsonNode> subscribeChannel(String channelName,
 Object... args)

Overrides:

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

subscribeCurrencyPairChannel

public io.reactivex.rxjava3.core.Observable<List<PoloniexWebSocketEvent>> subscribeCurrencyPairChannel(CurrencyPair currencyPair)

getChannelNameFromMessage

protected String getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)

Specified by:

getChannelNameFromMessage 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