public class WebSocketEventProducer
extends org.java_websocket.client.WebSocketClient
Constructor and Description |
---|
WebSocketEventProducer(String url,
ExchangeEventListener exchangeEventListener,
Map<String,String> headers,
ReconnectService reconnectService)
Constructor
|
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) |
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
public WebSocketEventProducer(String url, ExchangeEventListener exchangeEventListener, Map<String,String> headers, ReconnectService reconnectService) throws URISyntaxException
url
- exchangeEventListener
- headers
- URISyntaxException
public void onOpen(org.java_websocket.handshake.ServerHandshake handshakedata)
onOpen
in class org.java_websocket.client.WebSocketClient
public void onMessage(String message)
onMessage
in class org.java_websocket.client.WebSocketClient
public void onWebsocketMessageFragment(org.java_websocket.WebSocket conn, org.java_websocket.framing.Framedata frame)
onWebsocketMessageFragment
in interface org.java_websocket.WebSocketListener
onWebsocketMessageFragment
in class org.java_websocket.client.WebSocketClient
public org.java_websocket.framing.Framedata getLastFragmentedMessage()
public void onClose(int code, String reason, boolean remote)
onClose
in class org.java_websocket.client.WebSocketClient
public void onError(Exception ex)
onError
in class org.java_websocket.client.WebSocketClient
Copyright © 2012–2018 Xeiam, LLC. All rights reserved.