public class OkCoinStreamingExchangeService extends Object implements StreamingExchangeService
Constructor and Description |
---|
OkCoinStreamingExchangeService(ExchangeSpecification exchangeSpecification,
ExchangeStreamingConfiguration exchangeStreamingConfiguration) |
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.
|
public OkCoinStreamingExchangeService(ExchangeSpecification exchangeSpecification, ExchangeStreamingConfiguration exchangeStreamingConfiguration)
public void connect()
StreamingExchangeService
Opens the connection to the upstream server for this instance.
connect
in interface StreamingExchangeService
public void disconnect()
StreamingExchangeService
Closes the connection to the upstream server for this instance.
disconnect
in interface StreamingExchangeService
public ExchangeEvent getNextEvent() throws InterruptedException
StreamingExchangeService
Returns next event in consumer event queue, then removes it.
getNextEvent
in interface StreamingExchangeService
InterruptedException
public int countEventsAvailable()
Returns number of events in consumer event queue.
countEventsAvailable
in interface StreamingExchangeService
public void send(String msg)
StreamingExchangeService
Sends a msg over the socket.
send
in interface StreamingExchangeService
public org.java_websocket.WebSocket.READYSTATE getWebSocketStatus()
StreamingExchangeService
getWebSocketStatus
in interface StreamingExchangeService
Copyright © 2012–2018 Xeiam, LLC. All rights reserved.