co.tinode.tinodesdk

Class Connection

java.lang.Object

org.java_websocket.WebSocketAdapter

org.java_websocket.AbstractWebSocket

org.java_websocket.client.WebSocketClient

co.tinode.tinodesdk.Connection

All Implemented Interfaces:

java.lang.Runnable, org.java_websocket.WebSocket, org.java_websocket.WebSocketListener

public class Connection
extends org.java_websocket.client.WebSocketClient

A thinly wrapped websocket connection.

Field Summary

Fields inherited from class org.java_websocket.client.WebSocketClient

uri

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Connection(java.net.URI endpoint, java.lang.String apikey, co.tinode.tinodesdk.Connection.WsListener listener)

Method Summary

Modifier and Type	Method and Description
void	backoffReset() Reset exponential backoff counter to zero.
void	connect(boolean autoReconnect, boolean background) Establish a connection with the server.
void	disconnect() Gracefully close websocket connection.
boolean	isConnected() Check if the socket is OPEN.
boolean	isWaitingToReconnect() Check if the socket is waiting to reconnect.
void	onClose(int code, java.lang.String reason, boolean remote)
void	onError(java.lang.Exception ex)
void	onMessage(java.nio.ByteBuffer blob)
void	onMessage(java.lang.String message)
void	onOpen(org.java_websocket.handshake.ServerHandshake handshakeData)

Methods inherited from class org.java_websocket.client.WebSocketClient

addHeader, clearHeaders, close, close, close, closeBlocking, closeConnection, connect, connectBlocking, connectBlocking, getAttachment, getConnection, getConnections, getDraft, getLocalSocketAddress, getLocalSocketAddress, getReadyState, getRemoteSocketAddress, getRemoteSocketAddress, getResourceDescriptor, getSocket, getSSLSession, getURI, hasBufferedData, hasSSLSupport, isClosed, isClosing, isFlushAndClose, isOpen, onCloseInitiated, onClosing, onWebsocketClose, onWebsocketCloseInitiated, onWebsocketClosing, onWebsocketError, onWebsocketMessage, onWebsocketMessage, onWebsocketOpen, onWriteDemand, reconnect, reconnectBlocking, removeHeader, run, send, send, send, sendFragmentedFrame, sendFrame, sendFrame, sendPing, setAttachment, setDnsResolver, setProxy, setSocket, setSocketFactory

Methods inherited from class org.java_websocket.AbstractWebSocket

getConnectionLostTimeout, isReuseAddr, isTcpNoDelay, setConnectionLostTimeout, setReuseAddr, setTcpNoDelay, startConnectionLostTimer, stopConnectionLostTimer

Methods inherited from class org.java_websocket.WebSocketAdapter

onPreparePing, 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

Connection

protected Connection(java.net.URI endpoint,
                     java.lang.String apikey,
                     co.tinode.tinodesdk.Connection.WsListener listener)

Method Detail

connect

public void connect(boolean autoReconnect,
                    boolean background)

Establish a connection with the server. It opens or reopens a websocket in a separate thread. This is a non-blocking call.

Parameters:

autoReconnect - if connection is dropped, reconnect automatically

disconnect

public void disconnect()

Gracefully close websocket connection. The socket will attempt to send a frame to the server. The call is idempotent: if connection is already closed it does nothing.

isConnected

public boolean isConnected()

Check if the socket is OPEN.

Returns:

true if the socket is OPEN, false otherwise;

isWaitingToReconnect

public boolean isWaitingToReconnect()

Check if the socket is waiting to reconnect.

Returns:

true if the socket is OPEN, false otherwise;

backoffReset

public void backoffReset()

Reset exponential backoff counter to zero. If autoreconnect is true and WsListener is provided, then WsListener.onConnect must call this method.

onOpen

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

Specified by:

onOpen in class org.java_websocket.client.WebSocketClient

onMessage

public void onMessage(java.lang.String message)

Specified by:

onMessage in class org.java_websocket.client.WebSocketClient

onMessage

public void onMessage(java.nio.ByteBuffer blob)

Overrides:

onMessage in class org.java_websocket.client.WebSocketClient

onClose

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

Specified by:

onClose in class org.java_websocket.client.WebSocketClient

onError

public void onError(java.lang.Exception ex)

Specified by:

onError in class org.java_websocket.client.WebSocketClient