io.micronaut.http.server.netty.websocket

Class NettyServerWebSocketHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<Object>

io.micronaut.http.netty.websocket.AbstractNettyWebSocketHandler

io.micronaut.http.server.netty.websocket.NettyServerWebSocketHandler

All Implemented Interfaces:

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

@Internal
public class NettyServerWebSocketHandler
extends AbstractNettyWebSocketHandler

A handler for WebSocketFrame instances.

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.

Fields inherited from class io.micronaut.http.netty.websocket.AbstractNettyWebSocketHandler

LOG, mediaTypeCodecRegistry, messageHandler, originatingRequest, session, uriVariables, webSocketBean, webSocketBinder, webSocketSessionRepository, webSocketVersion

Method Summary

Modifier and Type	Method and Description
boolean	acceptInboundMessage(Object msg)
protected NettyRxWebSocketSession	createWebSocketSession(io.netty.channel.ChannelHandlerContext ctx) Subclasses should implement to create the actual NettyRxWebSocketSession.
void	handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)
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.
void	userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)

Methods inherited from class io.micronaut.http.netty.websocket.AbstractNettyWebSocketHandler

channelRead0, exceptionCaught, getBodyArgument, getSession, handleWebSocketFrame, writeCloseFrameAndTerminate

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged

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

Method Detail

userEventTriggered

public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx,
                               Object evt)
                        throws Exception

Specified by:

userEventTriggered in interface io.netty.channel.ChannelInboundHandler

Overrides:

userEventTriggered in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

acceptInboundMessage

public boolean acceptInboundMessage(Object msg)

Overrides:

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

createWebSocketSession

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

Description copied from class: AbstractNettyWebSocketHandler

Subclasses should implement to create the actual NettyRxWebSocketSession.

Specified by:

createWebSocketSession in class AbstractNettyWebSocketHandler

Parameters:

ctx - The context

Returns:

The session

instrumentPublisher

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

Description copied from class: AbstractNettyWebSocketHandler

Subclasses can override to customize publishers returned from message handlers.

Overrides:

instrumentPublisher in class AbstractNettyWebSocketHandler

Parameters:

ctx - The context

result - The result

Returns:

The flowable

invokeExecutable

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

Description copied from class: AbstractNettyWebSocketHandler

Invokes the given executable.

Overrides:

invokeExecutable in class AbstractNettyWebSocketHandler

Parameters:

boundExecutable - The bound executable

messageHandler - The message handler

Returns:

The result

messageHandled

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

Description copied from class: AbstractNettyWebSocketHandler

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

Overrides:

messageHandled in class AbstractNettyWebSocketHandler

Parameters:

ctx - The channel handler context

session - The session

message - The message that was handled

handlerRemoved

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

Specified by:

handlerRemoved in interface io.netty.channel.ChannelHandler

Overrides:

handlerRemoved in class AbstractNettyWebSocketHandler

Throws:

Exception