org.oxerr.okcoin.websocket

Class OKCoinClientEndpoint

java.lang.Object

org.oxerr.okcoin.websocket.OKCoinClientEndpoint

public final class OKCoinClientEndpoint
extends Object

OKCoin WebSocket client endpoint.

Constructor Summary

Constructors

Constructor and Description
OKCoinClientEndpoint()

Method Summary

Modifier and Type	Method and Description
void	addChannel(javax.websocket.Session session, String channel)
void	addChannel(javax.websocket.Session session, String channel, Map<String,String> parameters)
void	addChannelListener(String channel, OKCoinDataListener listener)
void	onClose(javax.websocket.Session session, javax.websocket.CloseReason reason)
void	onError(javax.websocket.Session session, Throwable throwable)
void	onMessage(javax.websocket.Session session, OKCoinData[] data)
void	onOpen(javax.websocket.Session session, javax.websocket.EndpointConfig config)
void	removeChannel(javax.websocket.Session session, String channel)

Methods inherited from class java.lang.Object

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

Constructor Detail

OKCoinClientEndpoint

public OKCoinClientEndpoint()

Method Detail

onOpen

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

onMessage

public void onMessage(javax.websocket.Session session,
                      OKCoinData[] data)
               throws IOException,
                      javax.websocket.EncodeException

Throws:

IOException

javax.websocket.EncodeException

onClose

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

onError

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

addChannelListener

public void addChannelListener(String channel,
                               OKCoinDataListener listener)

addChannel

public void addChannel(javax.websocket.Session session,
                       String channel)

addChannel

public void addChannel(javax.websocket.Session session,
                       String channel,
                       Map<String,String> parameters)

removeChannel

public void removeChannel(javax.websocket.Session session,
                          String channel)