Package info.bitrich.xchangestream.krakenfutures

Class KrakenFuturesStreamingService

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.krakenfutures.KrakenFuturesStreamingService

public class KrakenFuturesStreamingService
extends JsonNettyStreamingService

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 String	FILLS
protected final String	ORDERBOOK
protected final String	TICKER
protected final String	TRADES

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
KrakenFuturesStreamingService(String apiUrl, ExchangeSpecification exchangeSpecification)

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)
protected io.reactivex.Completable	openConnection()

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, getWebSocketClientExtensionHandler, getWebSocketClientHandler, handleChannelError, handleChannelMessage, handleError, handleIdle, isSocketOpen, 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

ORDERBOOK

protected final String ORDERBOOK

See Also:

• Constant Field Values

TICKER

protected final String TICKER

See Also:

• Constant Field Values

TRADES

protected final String TRADES

See Also:

• Constant Field Values

FILLS

protected final String FILLS

See Also:

• Constant Field Values

Constructor Details

KrakenFuturesStreamingService

public KrakenFuturesStreamingService(String apiUrl,
 ExchangeSpecification exchangeSpecification)

Method Details

getChannelNameFromMessage

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

Specified by:

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

handleMessage

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

Overrides:

handleMessage 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

openConnection

protected io.reactivex.Completable openConnection()

Overrides:

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