Package info.bitrich.xchangestream.kraken

Class KrakenPrivateStreamingService

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.kraken.KrakenStreamingService

info.bitrich.xchangestream.kraken.KrakenPrivateStreamingService

public class KrakenPrivateStreamingService
extends KrakenStreamingService

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 KrakenAuthenticated	krakenAuthenticated
protected KrakenStreamingExchange	krakenStreamingExchange
protected si.mazi.rescu.ParamsDigest	signatureCreator

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

objectMapper

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

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
KrakenPrivateStreamingService(String apiUri, KrakenStreamingExchange exchange)

Method Summary

Modifier and Type	Method	Description
String	getSubscribeMessage(String channelName, Object... args)
String	getUnsubscribeMessage(String subscriptionUniqueId, Object... args)

Methods inherited from class info.bitrich.xchangestream.kraken.KrakenStreamingService

disconnect, getChannelNameFromMessage, getWebSocketClientExtensionHandler, getWebSocketClientHandler, handleMessage, processArrayMessageSeparately, sendMessage, subscribeSystemChannel

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

messageHandler, sendObjectMessage

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

getChannel, getCustomHeaders, getSubscriptionUniqueId, handleChannelError, handleChannelMessage, handleError, handleIdle, isSocketOpen, openConnection, resubscribeChannels, 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

krakenStreamingExchange

protected KrakenStreamingExchange krakenStreamingExchange

krakenAuthenticated

protected KrakenAuthenticated krakenAuthenticated

signatureCreator

protected si.mazi.rescu.ParamsDigest signatureCreator

Constructor Details

KrakenPrivateStreamingService

public KrakenPrivateStreamingService(String apiUri,
 KrakenStreamingExchange exchange)

Method Details

getSubscribeMessage

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

Overrides:

getSubscribeMessage in class KrakenStreamingService

Returns:

subscribe message containing a websocket token needed for private channels

Throws:

IOException

getUnsubscribeMessage

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

Overrides:

getUnsubscribeMessage in class KrakenStreamingService

Returns:

unsubscribe message containing a websocket token needed for private channels

Throws:

IOException