com.xeiam.xchange.mexbt.service.streaming

Class MeXBTTickerClientEndpoint

java.lang.Object

com.xeiam.xchange.mexbt.service.streaming.MeXBTTickerClientEndpoint

public final class MeXBTTickerClientEndpoint
extends Object

Constructor Summary

Constructors

Constructor and Description
MeXBTTickerClientEndpoint(BlockingQueue<ExchangeEvent> exchangeEvents)

Method Summary

Modifier and Type	Method and Description
void	onClose(javax.websocket.Session session, javax.websocket.CloseReason reason)
void	onError(javax.websocket.Session session, Throwable throwable)
void	onMessage(javax.websocket.Session session, MeXBTStreamingTicker ticker)
void	onOpen(javax.websocket.Session session, javax.websocket.EndpointConfig config)

Methods inherited from class java.lang.Object

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

Constructor Detail

MeXBTTickerClientEndpoint

public MeXBTTickerClientEndpoint(BlockingQueue<ExchangeEvent> exchangeEvents)

Method Detail

onOpen

public void onOpen(javax.websocket.Session session,
                   javax.websocket.EndpointConfig config)

onMessage

public void onMessage(javax.websocket.Session session,
                      MeXBTStreamingTicker ticker)
               throws InterruptedException

Throws:

InterruptedException

onClose

public void onClose(javax.websocket.Session session,
                    javax.websocket.CloseReason reason)

onError

public void onError(javax.websocket.Session session,
                    Throwable throwable)