class WebSocketsServer extends org.eclipse.jetty.server.Server
Modifier and Type | Class and Description |
---|---|
private class |
WebSocketsServer.PluginWebSocket |
org.eclipse.jetty.server.Server.Graceful
Modifier and Type | Field and Description |
---|---|
private DeepaMehtaService |
dms |
private Logger |
logger |
private Map<String,Queue<org.eclipse.jetty.websocket.WebSocket.Connection>> |
pluginConnections |
private static DeepaMehtaEvent |
WEBSOCKET_TEXT_MESSAGE |
Constructor and Description |
---|
WebSocketsServer(int port,
DeepaMehtaService dms) |
Modifier and Type | Method and Description |
---|---|
private void |
addConnection(String pluginUri,
org.eclipse.jetty.websocket.WebSocket.Connection connection) |
(package private) void |
broadcast(String pluginUri,
String message) |
private Queue<org.eclipse.jetty.websocket.WebSocket.Connection> |
getConnections(String pluginUri)
Returns the open WebSocket connections associated to the given plugin, or
null if there are none. |
private void |
removeConnection(String pluginUri,
org.eclipse.jetty.websocket.WebSocket.Connection connection) |
addBean, addConnector, addLifeCycle, clearAttributes, doStart, doStop, dump, getAttribute, getAttributeNames, getConnectors, getContainer, getGracefulShutdown, getMaxCookieVersion, getSendDateHeader, getSendServerVersion, getSessionIdManager, getStopAtShutdown, getThreadPool, getVersion, handle, handleAsync, isDumpAfterStart, isDumpBeforeStop, isUncheckedPrintWriter, join, main, removeAttribute, removeBean, removeConnector, removeLifeCycle, setAttribute, setConnectors, setDumpAfterStart, setDumpBeforeStop, setGracefulShutdown, setMaxCookieVersion, setSendDateHeader, setSendServerVersion, setSessionIdManager, setStopAtShutdown, setThreadPool, setUncheckedPrintWriter, toString
destroy, expandChildren, getHandler, getHandlers, getNestedHandlerByClass, handle, setHandler, setServer
expandHandler, findContainerOf, getChildHandlerByClass, getChildHandlers, getChildHandlersByClass
addBean, contains, dump, dump, dump, dump, dumpObject, dumpStdErr, getBean, getBeans, getBeans, isManaged, manage, removeBeans, unmanage
addLifeCycleListener, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
private static DeepaMehtaEvent WEBSOCKET_TEXT_MESSAGE
private Map<String,Queue<org.eclipse.jetty.websocket.WebSocket.Connection>> pluginConnections
private DeepaMehtaService dms
WebSocketsServer(int port, DeepaMehtaService dms)
private Queue<org.eclipse.jetty.websocket.WebSocket.Connection> getConnections(String pluginUri)
null
if there are none.private void addConnection(String pluginUri, org.eclipse.jetty.websocket.WebSocket.Connection connection)
private void removeConnection(String pluginUri, org.eclipse.jetty.websocket.WebSocket.Connection connection)
Copyright © 2016. All Rights Reserved.