com.appunite.websocket

Class WebSocketConnection

java.lang.Object

com.appunite.websocket.WebSocketConnection

All Implemented Interfaces:

WebSocketSender

public class WebSocketConnection
extends java.lang.Object
implements WebSocketSender

Class represents single web socket connection

Method Summary

Methods

Modifier and Type	Method and Description
void	connect() Connect to websocket
void	interrupt() Interrupt connect method.
void	sendByteMessage(byte[] buffer) Send binary message (thread safe).
void	sendPingMessage(byte[] buffer) Send ping request (thread safe).
void	sendStringMessage(java.lang.String message) Send text message (thread safe).

Methods inherited from class java.lang.Object

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

Method Detail

connect

public void connect()
             throws WrongWebsocketResponse,
                    java.lang.InterruptedException,
                    java.io.IOException

Connect to websocket

Throws:

java.net.UnknownHostException - when could not connect to selected host

java.io.IOException - thrown when I/O exception occur

WrongWebsocketResponse - thrown when wrong web socket response received

java.lang.InterruptedException - thrown when interrupt method was invoked

sendByteMessage

public void sendByteMessage(@Nonnull
                   byte[] buffer)
                     throws java.io.IOException,
                            java.lang.InterruptedException,
                            NotConnectedException

Description copied from interface: WebSocketSender

Send binary message (thread safe). Can be called after onConnect and before onDisconnect by any thread. Thread will be blocked until send

Specified by:

sendByteMessage in interface WebSocketSender

Parameters:

buffer - buffer to send

Throws:

java.io.IOException - when exception occur while sending

java.lang.InterruptedException - when user call disconnect

NotConnectedException - when called before onConnect or after onDisconnect

sendPingMessage

public void sendPingMessage(@Nonnull
                   byte[] buffer)
                     throws java.io.IOException,
                            java.lang.InterruptedException,
                            NotConnectedException

Description copied from interface: WebSocketSender

Send ping request (thread safe). Can be called after onConnect and before onDisconnect by any thread. Thread will be blocked until send

Specified by:

sendPingMessage in interface WebSocketSender

Parameters:

buffer - buffer to send

Throws:

java.io.IOException - when exception occur while sending

java.lang.InterruptedException - when user call disconnect

NotConnectedException - when called before onConnect or after onDisconnect

sendStringMessage

public void sendStringMessage(@Nonnull
                     java.lang.String message)
                       throws java.io.IOException,
                              java.lang.InterruptedException,
                              NotConnectedException

Description copied from interface: WebSocketSender

Send text message (thread safe). Can be called after onConnect and before onDisconnect by any thread. Thread will be blocked until send

Specified by:

sendStringMessage in interface WebSocketSender

Parameters:

message - message to send

Throws:

java.io.IOException - when exception occur while sending

java.lang.InterruptedException - when user call disconnect

NotConnectedException - when called before onConnect or after onDisconnect

interrupt

public void interrupt()

Interrupt connect method. After interruption create should return InterruptedException (thread safe)