com.xeiam.xchange.mexbt.service.streaming

Class MeXBTStreamingService

java.lang.Object

com.xeiam.xchange.mexbt.service.streaming.MeXBTStreamingService

All Implemented Interfaces:

StreamingExchangeService

public class MeXBTStreamingService
extends Object
implements StreamingExchangeService

Constructor Summary

Constructors

Constructor and Description
MeXBTStreamingService(Exchange exchange)
MeXBTStreamingService(Exchange exchange, MeXBTExchangeStreamingConfiguration configuration)

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

MeXBTStreamingService

public MeXBTStreamingService(Exchange exchange)

MeXBTStreamingService

public MeXBTStreamingService(Exchange exchange,
                             MeXBTExchangeStreamingConfiguration configuration)

Method Detail

connect

public void connect()

Opens the connection to the upstream server for this instance.

Specified by:

connect in interface StreamingExchangeService

disconnect

public void disconnect()

Closes the connection to the upstream server for this instance.

Specified by:

disconnect in interface StreamingExchangeService

getNextEvent

public ExchangeEvent getNextEvent()
                           throws InterruptedException

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)

Sends a msg over the socket.

Specified by:

send in interface StreamingExchangeService

getWebSocketStatus

public org.java_websocket.WebSocket.READYSTATE getWebSocketStatus()

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