io.micronaut.http.netty.websocket

Class AbstractNettyWebSocketHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<Object>

io.micronaut.http.netty.websocket.AbstractNettyWebSocketHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

Direct Known Subclasses:

NettyServerWebSocketHandler, NettyWebSocketClientHandler

@Internal
public abstract class AbstractNettyWebSocketHandler
extends io.netty.channel.SimpleChannelInboundHandler<Object>

Abstract implementation that handles WebSocket frames.

Since:

1.0

Author:

graemerocher

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
static String	ID The id of the handler used when adding it to the Netty pipeline.
protected org.slf4j.Logger	LOG
protected MediaTypeCodecRegistry	mediaTypeCodecRegistry
protected MethodExecutionHandle<?,?>	messageHandler
protected HttpRequest<?>	originatingRequest
protected NettyRxWebSocketSession	session
protected Map<String,Object>	uriVariables
protected WebSocketBean<?>	webSocketBean
protected ArgumentBinderRegistry<WebSocketState>	webSocketBinder
protected WebSocketSessionRepository	webSocketSessionRepository
protected io.netty.handler.codec.http.websocketx.WebSocketVersion	webSocketVersion

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractNettyWebSocketHandler(io.netty.channel.ChannelHandlerContext ctx, RequestBinderRegistry binderRegistry, MediaTypeCodecRegistry mediaTypeCodecRegistry, WebSocketBean<?> webSocketBean, HttpRequest<?> request, Map<String,Object> uriVariables, io.netty.handler.codec.http.websocketx.WebSocketVersion version, WebSocketSessionRepository webSocketSessionRepository) Default constructor.

Method Summary

Modifier and Type	Method and Description
protected void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, Object msg)
protected abstract NettyRxWebSocketSession	createWebSocketSession(io.netty.channel.ChannelHandlerContext ctx) Subclasses should implement to create the actual NettyRxWebSocketSession.
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
Argument<?>	getBodyArgument()
NettyRxWebSocketSession	getSession()
void	handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)
protected void	handleWebSocketFrame(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.websocketx.WebSocketFrame msg) Handles WebSocket frame request.
protected io.reactivex.Flowable<?>	instrumentPublisher(io.netty.channel.ChannelHandlerContext ctx, Object result) Subclasses can override to customize publishers returned from message handlers.
protected Object	invokeExecutable(BoundExecutable boundExecutable, MethodExecutionHandle<?,?> messageHandler) Invokes the given executable.
protected void	messageHandled(io.netty.channel.ChannelHandlerContext ctx, NettyRxWebSocketSession session, Object message) Method called once a message has been handled by the handler.
protected void	writeCloseFrameAndTerminate(io.netty.channel.ChannelHandlerContext ctx, CloseReason closeReason) Writes the give close reason and terminates the session.

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded

Field Detail

ID

public static final String ID

The id of the handler used when adding it to the Netty pipeline.

See Also:

Constant Field Values

LOG

protected final org.slf4j.Logger LOG

webSocketBinder

protected final ArgumentBinderRegistry<WebSocketState> webSocketBinder

uriVariables

protected final Map<String,Object> uriVariables

webSocketBean

protected final WebSocketBean<?> webSocketBean

originatingRequest

protected final HttpRequest<?> originatingRequest

messageHandler

protected final MethodExecutionHandle<?,?> messageHandler

session

protected final NettyRxWebSocketSession session

mediaTypeCodecRegistry

protected final MediaTypeCodecRegistry mediaTypeCodecRegistry

webSocketVersion

protected final io.netty.handler.codec.http.websocketx.WebSocketVersion webSocketVersion

webSocketSessionRepository

protected final WebSocketSessionRepository webSocketSessionRepository

Constructor Detail

AbstractNettyWebSocketHandler

protected AbstractNettyWebSocketHandler(io.netty.channel.ChannelHandlerContext ctx,
                                        RequestBinderRegistry binderRegistry,
                                        MediaTypeCodecRegistry mediaTypeCodecRegistry,
                                        WebSocketBean<?> webSocketBean,
                                        HttpRequest<?> request,
                                        Map<String,Object> uriVariables,
                                        io.netty.handler.codec.http.websocketx.WebSocketVersion version,
                                        WebSocketSessionRepository webSocketSessionRepository)

Default constructor.

Parameters:

ctx - The channel handler context

binderRegistry - The request binder registry

mediaTypeCodecRegistry - The codec registry

webSocketBean - The websocket bean

request - The originating request

uriVariables - The URI variables

version - The websocket version being used

webSocketSessionRepository - The web socket repository if they are supported (like on the server), null otherwise

Method Detail

getBodyArgument

public Argument<?> getBodyArgument()

Returns:

The body argument for the message handler

getSession

public NettyRxWebSocketSession getSession()

Returns:

The session

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                            Throwable cause)

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

handlerRemoved

public void handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)
                    throws Exception

Specified by:

handlerRemoved in interface io.netty.channel.ChannelHandler

Overrides:

handlerRemoved in class io.netty.channel.ChannelHandlerAdapter

Throws:

Exception

createWebSocketSession

protected abstract NettyRxWebSocketSession createWebSocketSession(io.netty.channel.ChannelHandlerContext ctx)

Subclasses should implement to create the actual NettyRxWebSocketSession.

Parameters:

ctx - The context

Returns:

The session

instrumentPublisher

protected io.reactivex.Flowable<?> instrumentPublisher(io.netty.channel.ChannelHandlerContext ctx,
                                                       Object result)

Subclasses can override to customize publishers returned from message handlers.

Parameters:

ctx - The context

result - The result

Returns:

The flowable

invokeExecutable

protected Object invokeExecutable(BoundExecutable boundExecutable,
                                  MethodExecutionHandle<?,?> messageHandler)

Invokes the given executable.

Parameters:

boundExecutable - The bound executable

messageHandler - The message handler

Returns:

The result

channelRead0

protected void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                            Object msg)

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<Object>

handleWebSocketFrame

protected void handleWebSocketFrame(io.netty.channel.ChannelHandlerContext ctx,
                                    io.netty.handler.codec.http.websocketx.WebSocketFrame msg)

Handles WebSocket frame request.

Parameters:

ctx - The context

msg - The frame

messageHandled

protected void messageHandled(io.netty.channel.ChannelHandlerContext ctx,
                              NettyRxWebSocketSession session,
                              Object message)

Method called once a message has been handled by the handler.

Parameters:

ctx - The channel handler context

session - The session

message - The message that was handled

writeCloseFrameAndTerminate

protected void writeCloseFrameAndTerminate(io.netty.channel.ChannelHandlerContext ctx,
                                           CloseReason closeReason)

Writes the give close reason and terminates the session.

Parameters:

ctx - The context

closeReason - The reason