Package info.bitrich.xchangestream.bitmex

Class BitmexStreamingService

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.bitmex.BitmexStreamingService

public class BitmexStreamingService
extends JsonNettyStreamingService

Created by Lukas Zaoralek on 13.11.17.

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
static final int	DMS_CANCEL_ALL_IN
static final int	DMS_RESUBSCRIBE

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
BitmexStreamingService(String apiUrl, String apiKey, String secretKey)
BitmexStreamingService(String apiUrl, String apiKey, String secretKey, int maxFramePayloadLength, Duration connectionTimeout, Duration retryDuration, int idleTimeoutSeconds)

Method Summary

Modifier and Type	Method	Description
void	addDelayEmitter(io.reactivex.rxjava3.core.ObservableEmitter<Long> delayEmitter)
io.reactivex.rxjava3.core.Completable	connect()
void	disableDeadMansSwitch()
void	enableDeadMansSwitch(long rate, long timeout)
protected String	getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
protected io.netty.handler.codec.http.DefaultHttpHeaders	getCustomHeaders()
String	getSubscribeMessage(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	isDeadMansSwitchEnabled()
io.reactivex.rxjava3.core.Observable<BitmexWebSocketTransaction>	subscribeBitmexChannel(String channelName)

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, getSubscriptionUniqueId, 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

Field Details

DMS_CANCEL_ALL_IN

public static final int DMS_CANCEL_ALL_IN

See Also:

• Constant Field Values

DMS_RESUBSCRIBE

public static final int DMS_RESUBSCRIBE

See Also:

• Constant Field Values

Constructor Details

BitmexStreamingService

public BitmexStreamingService(String apiUrl,
 String apiKey,
 String secretKey)

BitmexStreamingService

public BitmexStreamingService(String apiUrl,
 String apiKey,
 String secretKey,
 int maxFramePayloadLength,
 Duration connectionTimeout,
 Duration retryDuration,
 int idleTimeoutSeconds)

Method Details

connect

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

Overrides:

connect in class ConnectableService

handleMessage

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

Overrides:

handleMessage 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>

subscribeBitmexChannel

public io.reactivex.rxjava3.core.Observable<BitmexWebSocketTransaction> subscribeBitmexChannel(String channelName)

getCustomHeaders

protected io.netty.handler.codec.http.DefaultHttpHeaders getCustomHeaders()

Overrides:

getCustomHeaders 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

enableDeadMansSwitch

public void enableDeadMansSwitch(long rate,
 long timeout)
                          throws IOException

Throws:

IOException

disableDeadMansSwitch

public void disableDeadMansSwitch()
                           throws IOException

Throws:

IOException

isDeadMansSwitchEnabled

public boolean isDeadMansSwitchEnabled()

addDelayEmitter

public void addDelayEmitter(io.reactivex.rxjava3.core.ObservableEmitter<Long> delayEmitter)