Package info.bitrich.xchangestream.deribit

Class DeribitPrivateStreamingService

java.lang.Object

info.bitrich.xchangestream.service.ConnectableService

info.bitrich.xchangestream.service.netty.NettyStreamingService<DeribitWsNotification>

info.bitrich.xchangestream.deribit.DeribitStreamingService

info.bitrich.xchangestream.deribit.DeribitPrivateStreamingService

public class DeribitPrivateStreamingService
extends DeribitStreamingService

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.deribit.DeribitStreamingService

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
DeribitPrivateStreamingService(String apiUri, String apiKey, String apiSecret)

Method Summary

Modifier and Type	Method	Description
protected void	handleMessage(DeribitWsNotification message)
void	resubscribeChannels()	Sends login message right after connecting
void	resubscribeChannelsAfterLogin()

Methods inherited from class info.bitrich.xchangestream.deribit.DeribitStreamingService

getChannelNameFromMessage, getSubscribeMessage, getUnsubscribeMessage, messageHandler

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

disconnect, getChannel, getCustomHeaders, getSubscriptionUniqueId, getWebSocketClientExtensionHandler, 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

Methods inherited from class java.lang.Object

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

Constructor Details

DeribitPrivateStreamingService

public DeribitPrivateStreamingService(String apiUri,
 String apiKey,
 String apiSecret)

Method Details

resubscribeChannels

public void resubscribeChannels()

Sends login message right after connecting

Overrides:

resubscribeChannels in class NettyStreamingService<DeribitWsNotification>

resubscribeChannelsAfterLogin

public void resubscribeChannelsAfterLogin()

handleMessage

protected void handleMessage(DeribitWsNotification message)

Overrides:

handleMessage in class DeribitStreamingService