org.smallmind.web.grizzly.tyrus

Class TyrusGrizzlyFilter

java.lang.Object

org.glassfish.grizzly.filterchain.BaseFilter

org.smallmind.web.grizzly.tyrus.TyrusGrizzlyFilter

All Implemented Interfaces:

org.glassfish.grizzly.filterchain.Filter

public class TyrusGrizzlyFilter
extends org.glassfish.grizzly.filterchain.BaseFilter

WebSocket Filter implementation, which supposed to be placed into a FilterChain right after HTTP Filter: HttpServerFilter, HttpClientFilter; depending whether it's server or client side. The WebSocketFilter handles websocket connection, handshake phases and, when receives a websocket frame - redirects it to appropriate connection (TyrusEndpointWrapper, TyrusWebSocket) for processing.

Constructor Summary

Constructors

Constructor and Description
TyrusGrizzlyFilter(org.glassfish.tyrus.spi.WebSocketEngine websocketEngine, String contextPath)

Method Summary

Modifier and Type	Method and Description
org.glassfish.grizzly.filterchain.NextAction	handleClose(org.glassfish.grizzly.filterchain.FilterChainContext ctx) Method handles Grizzly Connection close phase.
org.glassfish.grizzly.filterchain.NextAction	handleRead(org.glassfish.grizzly.filterchain.FilterChainContext ctx) Handle Grizzly Connection read phase.

Methods inherited from class org.glassfish.grizzly.filterchain.BaseFilter

createContext, exceptionOccurred, handleAccept, handleConnect, handleEvent, handleWrite, onAdded, onFilterChainChanged, onRemoved, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

TyrusGrizzlyFilter

public TyrusGrizzlyFilter(org.glassfish.tyrus.spi.WebSocketEngine websocketEngine,
                          String contextPath)

Method Detail

handleClose

public org.glassfish.grizzly.filterchain.NextAction handleClose(org.glassfish.grizzly.filterchain.FilterChainContext ctx)
                                                         throws IOException

Method handles Grizzly Connection close phase. Check if the Connection is a TyrusWebSocket, if yes - tries to close the websocket gracefully (sending close frame) and calls TyrusWebSocket.onClose(org.glassfish.tyrus.core.frame.CloseFrame). If the Grizzly Connection is not websocket - passes processing to the next filter in the chain.

Specified by:

handleClose in interface org.glassfish.grizzly.filterchain.Filter

Overrides:

handleClose in class org.glassfish.grizzly.filterchain.BaseFilter

Parameters:

ctx - FilterChainContext

Returns:

NextAction instruction for FilterChain, how it should continue the execution

Throws:

IOException

handleRead

public org.glassfish.grizzly.filterchain.NextAction handleRead(org.glassfish.grizzly.filterchain.FilterChainContext ctx)
                                                        throws IOException

Handle Grizzly Connection read phase. If the Connection has associated TyrusWebSocket object (websocket connection), we check if websocket handshake has been completed for this connection, if not - initiate/validate handshake. If handshake has been completed - parse websocket Frames one by one and pass processing to appropriate TyrusWebSocket: TyrusEndpointWrapper for server- and client- side connections.

Specified by:

handleRead in interface org.glassfish.grizzly.filterchain.Filter

Overrides:

handleRead in class org.glassfish.grizzly.filterchain.BaseFilter

Parameters:

ctx - FilterChainContext

Returns:

NextAction instruction for FilterChain, how it should continue the execution

Throws:

IOException - TODO