com.xeiam.xchange.okcoin.service.streaming

Class OkCoinStreamingExchangeService

java.lang.Object

com.xeiam.xchange.okcoin.service.streaming.OkCoinStreamingExchangeService

All Implemented Interfaces:

StreamingExchangeService

public class OkCoinStreamingExchangeService
extends Object
implements StreamingExchangeService

Constructor Summary

Constructors

Constructor and Description
OkCoinStreamingExchangeService(ExchangeSpecification exchangeSpecification, ExchangeStreamingConfiguration exchangeStreamingConfiguration)

Method Summary

Modifier and Type	Method and Description
void	connect() Opens the connection to the upstream server for this instance.
int	countEventsAvailable() Returns number of events in consumer event queue.
void	disconnect() Closes the connection to the upstream server for this instance.
ExchangeEvent	getNextEvent() Returns next event in consumer event queue, then removes it.
org.java_websocket.WebSocket.READYSTATE	getWebSocketStatus() Returns current state of websocket connection.
void	send(String msg) Sends a msg over the socket.

Methods inherited from class java.lang.Object

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

Constructor Detail

OkCoinStreamingExchangeService

public OkCoinStreamingExchangeService(ExchangeSpecification exchangeSpecification,
                                      ExchangeStreamingConfiguration exchangeStreamingConfiguration)

Method Detail

connect

public void connect()

Description copied from interface: StreamingExchangeService

Opens the connection to the upstream server for this instance.

Specified by:

connect in interface StreamingExchangeService

disconnect

public void disconnect()

Description copied from interface: StreamingExchangeService

Closes the connection to the upstream server for this instance.

Specified by:

disconnect in interface StreamingExchangeService

getNextEvent

public ExchangeEvent getNextEvent()
                           throws InterruptedException

Description copied from interface: StreamingExchangeService

Returns next event in consumer event queue, then removes it.

Specified by:

getNextEvent in interface StreamingExchangeService

Returns:

An ExchangeEvent

Throws:

InterruptedException

countEventsAvailable

public int countEventsAvailable()

Returns number of events in consumer event queue.

Specified by:

countEventsAvailable in interface StreamingExchangeService

Returns:

An int

send

public void send(String msg)

Description copied from interface: StreamingExchangeService

Sends a msg over the socket.

Specified by:

send in interface StreamingExchangeService

getWebSocketStatus

public org.java_websocket.WebSocket.READYSTATE getWebSocketStatus()

Description copied from interface: StreamingExchangeService

Returns current state of websocket connection. Will return one of these values: NOT_YET_CONNECTED, CONNECTING, OPEN, CLOSING, CLOSED

Specified by:

getWebSocketStatus in interface StreamingExchangeService

Returns:

enum of type READYSTATE