com.xeiam.xchange.service.streaming

Class WebSocketEventProducer

java.lang.Object

org.java_websocket.WebSocketAdapter

org.java_websocket.client.WebSocketClient

com.xeiam.xchange.service.streaming.WebSocketEventProducer

All Implemented Interfaces:

Runnable, org.java_websocket.WebSocket, org.java_websocket.WebSocketListener

public class WebSocketEventProducer
extends org.java_websocket.client.WebSocketClient

Author:

timmolter, ObsessiveOrange

Nested Class Summary

Nested classes/interfaces inherited from interface org.java_websocket.WebSocket

org.java_websocket.WebSocket.READYSTATE, org.java_websocket.WebSocket.Role

Field Summary

Fields inherited from class org.java_websocket.client.WebSocketClient

uri

Fields inherited from interface org.java_websocket.WebSocket

DEFAULT_PORT, DEFAULT_WSS_PORT

Constructor Summary

Constructors

Constructor and Description
WebSocketEventProducer(String url, ExchangeEventListener exchangeEventListener, Map<String,String> headers, ReconnectService reconnectService) Constructor

Method Summary

Modifier and Type	Method and Description
org.java_websocket.framing.Framedata	getLastFragmentedMessage()
void	onClose(int code, String reason, boolean remote)
void	onError(Exception ex)
void	onMessage(String message)
void	onOpen(org.java_websocket.handshake.ServerHandshake handshakedata)
void	onWebsocketMessageFragment(org.java_websocket.WebSocket conn, org.java_websocket.framing.Framedata frame)

Methods inherited from class org.java_websocket.client.WebSocketClient

close, close, close, closeBlocking, closeConnection, connect, connectBlocking, getConnection, getDraft, getLocalSocketAddress, getLocalSocketAddress, getReadyState, getRemoteSocketAddress, getRemoteSocketAddress, getResourceDescriptor, getURI, hasBufferedData, isClosed, isClosing, isConnecting, isFlushAndClose, isOpen, onCloseInitiated, onClosing, onFragment, onMessage, onWebsocketClose, onWebsocketCloseInitiated, onWebsocketClosing, onWebsocketError, onWebsocketMessage, onWebsocketMessage, onWebsocketOpen, onWriteDemand, run, send, send, send, sendFragmentedFrame, sendFrame, setProxy, setSocket

Methods inherited from class org.java_websocket.WebSocketAdapter

getFlashPolicy, onWebsocketHandshakeReceivedAsClient, onWebsocketHandshakeReceivedAsServer, onWebsocketHandshakeSentAsClient, onWebsocketPing, onWebsocketPong

Methods inherited from class java.lang.Object

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

Constructor Detail

WebSocketEventProducer

public WebSocketEventProducer(String url,
                              ExchangeEventListener exchangeEventListener,
                              Map<String,String> headers,
                              ReconnectService reconnectService)
                       throws URISyntaxException

Constructor

Parameters:

url -

exchangeEventListener -

headers -

Throws:

URISyntaxException

Method Detail

onOpen

public void onOpen(org.java_websocket.handshake.ServerHandshake handshakedata)

Specified by:

onOpen in class org.java_websocket.client.WebSocketClient

onMessage

public void onMessage(String message)

Specified by:

onMessage in class org.java_websocket.client.WebSocketClient

onWebsocketMessageFragment

public void onWebsocketMessageFragment(org.java_websocket.WebSocket conn,
                                       org.java_websocket.framing.Framedata frame)

Specified by:

onWebsocketMessageFragment in interface org.java_websocket.WebSocketListener

Overrides:

onWebsocketMessageFragment in class org.java_websocket.client.WebSocketClient

getLastFragmentedMessage

public org.java_websocket.framing.Framedata getLastFragmentedMessage()

onClose

public void onClose(int code,
                    String reason,
                    boolean remote)

Specified by:

onClose in class org.java_websocket.client.WebSocketClient

onError

public void onError(Exception ex)

Specified by:

onError in class org.java_websocket.client.WebSocketClient