com.github.kklisura.cdt.services.impl

Class WebSocketServiceImpl

java.lang.Object

com.github.kklisura.cdt.services.impl.WebSocketServiceImpl

All Implemented Interfaces:

WebSocketService

public class WebSocketServiceImpl
extends Object
implements WebSocketService

Web socket service implementation.

Author:

Kenan Klisura

Field Summary

Fields

Modifier and Type	Field and Description
static String	WEB_SOCKET_CONTAINER_FACTORY_PROPERTY

Constructor Summary

Constructors

Constructor and Description
WebSocketServiceImpl(javax.websocket.Session session) Instantiates a new Web socket service.

Method Summary

Modifier and Type	Method and Description
void	addMessageHandler(Consumer<String> consumer) After receiving the message calls the consumer with appropriate message.
void	close() Closes the service.
boolean	closed() Checks if connection is closed.
void	connect(URI uri) Connects to a specified URI.
static WebSocketService	create(URI uri) Creates a web socket service implementation factory method.
static javax.websocket.WebSocketContainer	getWebSocketContainer() Returns a WebSocketContainer retrieved from class defined in system property com.github.kklisura.cdt.services.config.webSocketContainerProvider.
void	send(String message) Sends the message using web socket.

Methods inherited from class java.lang.Object

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

Field Detail

WEB_SOCKET_CONTAINER_FACTORY_PROPERTY

public static final String WEB_SOCKET_CONTAINER_FACTORY_PROPERTY

See Also:

Constant Field Values

Constructor Detail

WebSocketServiceImpl

public WebSocketServiceImpl(javax.websocket.Session session)

Instantiates a new Web socket service.

Parameters:

session - Session.

Method Detail

create

public static WebSocketService create(URI uri)
                               throws WebSocketServiceException

Creates a web socket service implementation factory method.

Creates a WebSocketService and connects to a specified uri.

Parameters:

uri - URI to connect to.

Returns:

WebSocketService implementation.

Throws:

WebSocketServiceException - If it fails to connect.

connect

public void connect(URI uri)
             throws WebSocketServiceException

Description copied from interface: WebSocketService

Connects to a specified URI.

Specified by:

connect in interface WebSocketService

Parameters:

uri - Server location.

Throws:

WebSocketServiceException

send

public void send(String message)
          throws WebSocketServiceException

Description copied from interface: WebSocketService

Sends the message using web socket.

Specified by:

send in interface WebSocketService

Parameters:

message - Message to send.

Throws:

WebSocketServiceException

addMessageHandler

public void addMessageHandler(Consumer<String> consumer)
                       throws WebSocketServiceException

Description copied from interface: WebSocketService

After receiving the message calls the consumer with appropriate message.

Specified by:

addMessageHandler in interface WebSocketService

Parameters:

consumer - Consumer to consume the message.

Throws:

WebSocketServiceException

close

public void close()

Description copied from interface: WebSocketService

Closes the service.

Specified by:

close in interface WebSocketService

closed

public boolean closed()

Description copied from interface: WebSocketService

Checks if connection is closed.

Specified by:

closed in interface WebSocketService

Returns:

True if connection is closed.

getWebSocketContainer

public static javax.websocket.WebSocketContainer getWebSocketContainer()

Returns a WebSocketContainer retrieved from class defined in system property com.github.kklisura.cdt.services.config.webSocketContainerProvider. The default value for this property is GrizzlyContainerProvider class FQN.

Returns:

WebSocketContainer.