|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.eclipse.jetty.util.component.AbstractLifeCycle org.eclipse.jetty.util.component.AggregateLifeCycle org.eclipse.jetty.server.handler.AbstractHandler org.eclipse.jetty.server.handler.AbstractHandlerContainer org.eclipse.jetty.server.handler.HandlerWrapper org.eclipse.jetty.server.Server de.deepamehta.plugins.websockets.WebSocketsServer
class WebSocketsServer
Nested Class Summary | |
---|---|
private class |
WebSocketsServer.PluginWebSocket
|
Nested classes/interfaces inherited from class org.eclipse.jetty.server.Server |
---|
org.eclipse.jetty.server.Server.Graceful |
Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle |
---|
org.eclipse.jetty.util.component.AbstractLifeCycle.AbstractLifeCycleListener |
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle |
---|
org.eclipse.jetty.util.component.LifeCycle.Listener |
Field Summary | |
---|---|
private DeepaMehtaService |
dms
|
private Logger |
logger
|
private Map<String,Queue<org.eclipse.jetty.websocket.WebSocket.Connection>> |
pluginConnections
|
private static DeepaMehtaEvent |
WEBSOCKET_TEXT_MESSAGE
|
Fields inherited from class org.eclipse.jetty.server.handler.HandlerWrapper |
---|
_handler |
Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle |
---|
_listeners, FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING |
Constructor Summary | |
---|---|
WebSocketsServer(int port,
DeepaMehtaService dms)
|
Method Summary | |
---|---|
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)
|
Methods inherited from class org.eclipse.jetty.server.Server |
---|
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 |
Methods inherited from class org.eclipse.jetty.server.handler.HandlerWrapper |
---|
destroy, expandChildren, getHandler, getHandlers, getNestedHandlerByClass, handle, setHandler, setServer |
Methods inherited from class org.eclipse.jetty.server.handler.AbstractHandlerContainer |
---|
expandHandler, findContainerOf, getChildHandlerByClass, getChildHandlers, getChildHandlersByClass |
Methods inherited from class org.eclipse.jetty.server.handler.AbstractHandler |
---|
dumpThis, getServer |
Methods inherited from class org.eclipse.jetty.util.component.AggregateLifeCycle |
---|
addBean, contains, dump, dump, dump, dump, dumpObject, dumpStdErr, getBean, getBeans, getBeans, isManaged, manage, removeBeans, unmanage |
Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle |
---|
addLifeCycleListener, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.eclipse.jetty.util.component.LifeCycle |
---|
addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop |
Field Detail |
---|
private static DeepaMehtaEvent WEBSOCKET_TEXT_MESSAGE
private Map<String,Queue<org.eclipse.jetty.websocket.WebSocket.Connection>> pluginConnections
private DeepaMehtaService dms
private Logger logger
Constructor Detail |
---|
WebSocketsServer(int port, DeepaMehtaService dms)
Method Detail |
---|
void broadcast(String pluginUri, String message)
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)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |