com.xeiam.xchange.bitstamp.service.streaming

Class BitstampPusherService

java.lang.Object

com.xeiam.xchange.service.BaseExchangeService

com.xeiam.xchange.bitstamp.service.polling.BitstampBasePollingService

com.xeiam.xchange.bitstamp.service.streaming.BitstampPusherService

All Implemented Interfaces:

BasePollingService, StreamingExchangeService

public class BitstampPusherService
extends BitstampBasePollingService
implements StreamingExchangeService

Streaming trade service for the Bitstamp exchange

Field Summary

Fields inherited from class com.xeiam.xchange.service.BaseExchangeService

exchange

Constructor Summary

Constructors

Constructor and Description
BitstampPusherService(Exchange exchange, BitstampStreamingConfiguration configuration) Constructor

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() Query the current state of the socket.
void	send(String msg) Sends a msg over the socket.

Methods inherited from class com.xeiam.xchange.service.BaseExchangeService

getExchangeSymbols, verifyOrder, verifyOrder, verifyOrder

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.xeiam.xchange.service.polling.BasePollingService

getExchangeSymbols

Constructor Detail

BitstampPusherService

public BitstampPusherService(Exchange exchange,
                             BitstampStreamingConfiguration configuration)

Constructor

Parameters:

exchange -

configuration -

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

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()

Query the current state of the socket.

Specified by:

getWebSocketStatus in interface StreamingExchangeService

Returns:

enum of type READYSTATE