org.oxerr.huobi.xchange.service.streaming

Class HuobiSocketIOService

java.lang.Object

org.oxerr.huobi.xchange.service.streaming.HuobiSocketIOService

All Implemented Interfaces:

com.xeiam.xchange.service.streaming.StreamingExchangeService

public class HuobiSocketIOService
extends Object
implements com.xeiam.xchange.service.streaming.StreamingExchangeService

Huobi streaming service implementation over WebSocket Market API.

Constructor Summary

Constructors

Constructor and Description
HuobiSocketIOService(com.xeiam.xchange.ExchangeSpecification exchangeSpecification, HuobiStreamingConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
void	connect()
void	disconnect()
com.xeiam.xchange.service.streaming.ExchangeEvent	getNextEvent()
org.java_websocket.WebSocket.READYSTATE	getWebSocketStatus()
void	send(String msg)

Methods inherited from class java.lang.Object

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

Constructor Detail

HuobiSocketIOService

public HuobiSocketIOService(com.xeiam.xchange.ExchangeSpecification exchangeSpecification,
                            HuobiStreamingConfiguration configuration)

Method Detail

connect

public void connect()

Specified by:

connect in interface com.xeiam.xchange.service.streaming.StreamingExchangeService

disconnect

public void disconnect()

Specified by:

disconnect in interface com.xeiam.xchange.service.streaming.StreamingExchangeService

getNextEvent

public com.xeiam.xchange.service.streaming.ExchangeEvent getNextEvent()
                                                               throws InterruptedException

Specified by:

getNextEvent in interface com.xeiam.xchange.service.streaming.StreamingExchangeService

Throws:

InterruptedException

send

public void send(String msg)

Specified by:

send in interface com.xeiam.xchange.service.streaming.StreamingExchangeService

getWebSocketStatus

public org.java_websocket.WebSocket.READYSTATE getWebSocketStatus()

Specified by:

getWebSocketStatus in interface com.xeiam.xchange.service.streaming.StreamingExchangeService