public final class MeXBTTickerClientEndpoint extends Object
Constructor and Description |
---|
MeXBTTickerClientEndpoint(BlockingQueue<ExchangeEvent> exchangeEvents) |
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) |
public MeXBTTickerClientEndpoint(BlockingQueue<ExchangeEvent> exchangeEvents)
public void onOpen(javax.websocket.Session session, javax.websocket.EndpointConfig config)
public void onMessage(javax.websocket.Session session, MeXBTStreamingTicker ticker) throws InterruptedException
InterruptedException
public void onClose(javax.websocket.Session session, javax.websocket.CloseReason reason)
public void onError(javax.websocket.Session session, Throwable throwable)
Copyright © 2012–2018 Xeiam, LLC. All rights reserved.