systems.dmx.core.impl

Class WebSocketsServiceImpl

Show UML class diagram

java.lang.Object

systems.dmx.core.impl.WebSocketsServiceImpl

All Implemented Interfaces:

WebSocketsService

class WebSocketsServiceImpl
extends Object
implements WebSocketsService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	WebSocketsServiceImpl.QueuedMessage
private class	WebSocketsServiceImpl.SendMessageWorker
private class	WebSocketsServiceImpl.WebSocketsServer

Field Summary

Fields

Modifier and Type	Field and Description
private CoreService	dmx
private Logger	logger
private WebSocketConnectionPool	pool
private WebSocketsServiceImpl.WebSocketsServer	server
private static int	WEBSOCKETS_PORT
private static String	WEBSOCKETS_URL
private WebSocketsServiceImpl.SendMessageWorker	worker

Constructor Summary

Constructors

Constructor and Description
WebSocketsServiceImpl(CoreService dmx)

Method Summary

Modifier and Type	Method and Description
private void	broadcast(String pluginUri, String message, WebSocketConnection exclude)
private WebSocketConnection	getConnection(javax.servlet.http.HttpServletRequest request, String pluginUri)
String	getWebSocketsURL()
private void	init()
void	messageToAll(String pluginUri, String message)
void	messageToAllButOne(javax.servlet.http.HttpServletRequest request, String pluginUri, String message)
void	messageToOne(javax.servlet.http.HttpServletRequest request, String pluginUri, String message)
private void	queueMessage(WebSocketConnection connection, String message)
(package private) void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

WEBSOCKETS_PORT

private static final int WEBSOCKETS_PORT

WEBSOCKETS_URL

private static final String WEBSOCKETS_URL

server

private WebSocketsServiceImpl.WebSocketsServer server

pool

private WebSocketConnectionPool pool

worker

private WebSocketsServiceImpl.SendMessageWorker worker

dmx

private CoreService dmx

logger

private Logger logger

Constructor Detail

WebSocketsServiceImpl

WebSocketsServiceImpl(CoreService dmx)

Method Detail

messageToAll

public void messageToAll(String pluginUri,
                         String message)

Specified by:

messageToAll in interface WebSocketsService

messageToAllButOne

public void messageToAllButOne(javax.servlet.http.HttpServletRequest request,
                               String pluginUri,
                               String message)

Specified by:

messageToAllButOne in interface WebSocketsService

messageToOne

public void messageToOne(javax.servlet.http.HttpServletRequest request,
                         String pluginUri,
                         String message)

Specified by:

messageToOne in interface WebSocketsService

getWebSocketsURL

public String getWebSocketsURL()

Specified by:

getWebSocketsURL in interface WebSocketsService

init

private void init()

shutdown

void shutdown()

getConnection

private WebSocketConnection getConnection(javax.servlet.http.HttpServletRequest request,
                                          String pluginUri)

Returns:

the WebSocket connection that is associated with the given request (based on its session cookie), or null if called outside request scope (e.g. while system startup).

Throws:

RuntimeException - if no valid session is associated with the request.

broadcast

private void broadcast(String pluginUri,
                       String message,
                       WebSocketConnection exclude)

queueMessage

private void queueMessage(WebSocketConnection connection,
                          String message)