services.moleculer.web.servlet.websocket

Class ServletWebSocketRegistry

java.lang.Object

services.moleculer.web.WebSocketRegistry

services.moleculer.web.servlet.websocket.ServletWebSocketRegistry

All Implemented Interfaces:

java.lang.Runnable, org.atmosphere.websocket.WebSocketHandler

public class ServletWebSocketRegistry
extends WebSocketRegistry
implements org.atmosphere.websocket.WebSocketHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected org.atmosphere.cpr.AtmosphereFramework	atmosphere

Fields inherited from class services.moleculer.web.WebSocketRegistry

readLock, registry, timer, webSocketFilter, writeLock

Constructor Summary

Constructors

Constructor and Description
ServletWebSocketRegistry(javax.servlet.ServletConfig config, services.moleculer.ServiceBroker broker, long cleanupSeconds, boolean async)

Method Summary

Modifier and Type	Method and Description
void	onByteMessage(org.atmosphere.websocket.WebSocket webSocket, byte[] data, int offset, int length)
void	onClose(org.atmosphere.websocket.WebSocket webSocket)
void	onError(org.atmosphere.websocket.WebSocket webSocket, org.atmosphere.websocket.WebSocketProcessor.WebSocketException t)
void	onOpen(org.atmosphere.websocket.WebSocket webSocket)
void	onTextMessage(org.atmosphere.websocket.WebSocket webSocket, java.lang.String data) Ping-pong simulation with a special message ("!").
void	service(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse rsp)
void	stopped()
protected Endpoint	toEnpoint(org.atmosphere.websocket.WebSocket webSocket)

Methods inherited from class services.moleculer.web.WebSocketRegistry

deregister, register, run, send, setWebSocketFilter

Methods inherited from class java.lang.Object

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

Field Detail

atmosphere

protected org.atmosphere.cpr.AtmosphereFramework atmosphere

Constructor Detail

ServletWebSocketRegistry

public ServletWebSocketRegistry(javax.servlet.ServletConfig config,
                                services.moleculer.ServiceBroker broker,
                                long cleanupSeconds,
                                boolean async)
                         throws javax.servlet.ServletException

Throws:

javax.servlet.ServletException

Method Detail

stopped

public void stopped()

Overrides:

stopped in class WebSocketRegistry

service

public void service(javax.servlet.http.HttpServletRequest req,
                    javax.servlet.http.HttpServletResponse rsp)
             throws java.io.IOException,
                    javax.servlet.ServletException

Throws:

java.io.IOException

javax.servlet.ServletException

onOpen

public void onOpen(org.atmosphere.websocket.WebSocket webSocket)
            throws java.io.IOException

Specified by:

onOpen in interface org.atmosphere.websocket.WebSocketHandler

Throws:

java.io.IOException

onByteMessage

public void onByteMessage(org.atmosphere.websocket.WebSocket webSocket,
                          byte[] data,
                          int offset,
                          int length)
                   throws java.io.IOException

Specified by:

onByteMessage in interface org.atmosphere.websocket.WebSocketHandler

Throws:

java.io.IOException

onTextMessage

public void onTextMessage(org.atmosphere.websocket.WebSocket webSocket,
                          java.lang.String data)
                   throws java.io.IOException

Ping-pong simulation with a special message ("!").

Specified by:

onTextMessage in interface org.atmosphere.websocket.WebSocketHandler

Throws:

java.io.IOException

onClose

public void onClose(org.atmosphere.websocket.WebSocket webSocket)

Specified by:

onClose in interface org.atmosphere.websocket.WebSocketHandler

onError

public void onError(org.atmosphere.websocket.WebSocket webSocket,
                    org.atmosphere.websocket.WebSocketProcessor.WebSocketException t)

Specified by:

onError in interface org.atmosphere.websocket.WebSocketHandler

toEnpoint

protected Endpoint toEnpoint(org.atmosphere.websocket.WebSocket webSocket)