cloud.artik.websocket

Class WebSocketProxy

java.lang.Object

cloud.artik.websocket.WebSocketProxy

All Implemented Interfaces:

okhttp3.ws.WebSocketListener

Direct Known Subclasses:

DeviceChannelWebSocket, FirehoseWebSocket

public class WebSocketProxy
extends Object
implements okhttp3.ws.WebSocketListener

Field Summary

Fields

Modifier and Type	Field and Description
protected ArtikCloudWebSocketCallback	callback
protected okhttp3.OkHttpClient	client
protected CountDownLatch	closeSignal
protected static String	host
protected JSON	json
protected CountDownLatch	openSignal
protected okhttp3.Request	request
protected ScheduledExecutorService	scheduler
protected ConnectionStatus	status
protected okhttp3.ws.WebSocket	webSocket

Constructor Summary

Constructors

Constructor and Description
WebSocketProxy(String url, okhttp3.OkHttpClient client, ArtikCloudWebSocketCallback callback)

Method Summary

Modifier and Type	Method and Description
protected String	asString(Throwable exc)
void	close()
void	closeBlocking()
void	connect()
void	connectBlocking()
ConnectionStatus	getConnectionStatus()
void	onClose(int code, String reason)
void	onFailure(IOException exc, okhttp3.Response response)
void	onMessage(okhttp3.ResponseBody response)
void	onOpen(okhttp3.ws.WebSocket webSocket, okhttp3.Response response)
void	onPong(okio.Buffer arg0)
protected void	sendObject(Object object)
static void	setHost(String host)

Methods inherited from class java.lang.Object

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

Field Detail

request

protected okhttp3.Request request

webSocket

protected okhttp3.ws.WebSocket webSocket

callback

protected ArtikCloudWebSocketCallback callback

client

protected okhttp3.OkHttpClient client

json

protected final JSON json

scheduler

protected final ScheduledExecutorService scheduler

status

protected ConnectionStatus status

openSignal

protected CountDownLatch openSignal

closeSignal

protected CountDownLatch closeSignal

host

protected static String host

Constructor Detail

WebSocketProxy

public WebSocketProxy(String url,
                      okhttp3.OkHttpClient client,
                      ArtikCloudWebSocketCallback callback)

Method Detail

setHost

public static void setHost(String host)

getConnectionStatus

public ConnectionStatus getConnectionStatus()

onOpen

public final void onOpen(okhttp3.ws.WebSocket webSocket,
                         okhttp3.Response response)

onClose

public final void onClose(int code,
                          String reason)

onFailure

public final void onFailure(IOException exc,
                            okhttp3.Response response)

asString

protected String asString(Throwable exc)

onMessage

public final void onMessage(okhttp3.ResponseBody response)
                     throws IOException

onPong

public final void onPong(okio.Buffer arg0)

connect

public final void connect()
                   throws IOException

connectBlocking

public final void connectBlocking()
                           throws IOException,
                                  InterruptedException

close

public final void close()
                 throws IOException

closeBlocking

public final void closeBlocking()
                         throws IOException,
                                InterruptedException

sendObject

protected void sendObject(Object object)
                   throws IOException