cloud.artik.websocket

Class WebSocketProxy

java.lang.Object

cloud.artik.websocket.WebSocketProxy

All Implemented Interfaces:

com.squareup.okhttp.ws.WebSocketListener

Direct Known Subclasses:

DeviceChannelWebSocket, FirehoseWebSocket

public class WebSocketProxy
extends Object
implements com.squareup.okhttp.ws.WebSocketListener

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
WebSocketProxy(String url, com.squareup.okhttp.OkHttpClient client, ArtikCloudWebSocketCallback callback)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeBlocking()
void	connect()
void	connectBlocking()
ConnectionStatus	getConnectionStatus()
void	onClose(int code, String reason)
void	onFailure(IOException exc, com.squareup.okhttp.Response response)
void	onMessage(com.squareup.okhttp.ResponseBody response)
void	onOpen(com.squareup.okhttp.ws.WebSocket webSocket, com.squareup.okhttp.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 com.squareup.okhttp.Request request

webSocket

protected com.squareup.okhttp.ws.WebSocket webSocket

callback

protected ArtikCloudWebSocketCallback callback

client

protected com.squareup.okhttp.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,
                      com.squareup.okhttp.OkHttpClient client,
                      ArtikCloudWebSocketCallback callback)

Method Detail

setHost

public static void setHost(String host)

getConnectionStatus

public ConnectionStatus getConnectionStatus()

onOpen

public final void onOpen(com.squareup.okhttp.ws.WebSocket webSocket,
                         com.squareup.okhttp.Response response)

onClose

public final void onClose(int code,
                          String reason)

onFailure

public final void onFailure(IOException exc,
                            com.squareup.okhttp.Response response)

onMessage

public final void onMessage(com.squareup.okhttp.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