io.micronaut.http.server.netty.websocket

Class NettyServerWebSocketUpgradeHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<NettyHttpRequest<?>>

io.micronaut.http.server.netty.websocket.NettyServerWebSocketUpgradeHandler

All Implemented Interfaces:

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

@Internal
public class NettyServerWebSocketUpgradeHandler
extends io.netty.channel.SimpleChannelInboundHandler<NettyHttpRequest<?>>

Handles WebSocket upgrade requests.

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 java.lang.String	COMPRESSION_HANDLER
static java.lang.String	ID
static java.lang.String	SCHEME_SECURE_WEBSOCKET
static java.lang.String	SCHEME_WEBSOCKET

Constructor Summary

Constructors

Constructor and Description
NettyServerWebSocketUpgradeHandler(NettyEmbeddedServices embeddedServices, WebSocketSessionRepository webSocketSessionRepository) Default constructor.

Method Summary

Modifier and Type	Method and Description
boolean	acceptInboundMessage(java.lang.Object msg)
protected void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, NettyHttpRequest<?> msg)
protected java.lang.String	getWebSocketURL(io.netty.channel.ChannelHandlerContext ctx, HttpRequest req) Obtains the web socket URL.
protected io.netty.channel.ChannelFuture	handleHandshake(io.netty.channel.ChannelHandlerContext ctx, NettyHttpRequest req, WebSocketBean<?> webSocketBean, MutableHttpResponse<?> response) Do the handshaking for WebSocket request.

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

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

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, 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, handlerRemoved

Field Detail

ID

public static final java.lang.String ID

See Also:

Constant Field Values

SCHEME_WEBSOCKET

public static final java.lang.String SCHEME_WEBSOCKET

See Also:

Constant Field Values

SCHEME_SECURE_WEBSOCKET

public static final java.lang.String SCHEME_SECURE_WEBSOCKET

See Also:

Constant Field Values

COMPRESSION_HANDLER

public static final java.lang.String COMPRESSION_HANDLER

See Also:

Constant Field Values

Constructor Detail

NettyServerWebSocketUpgradeHandler

public NettyServerWebSocketUpgradeHandler(NettyEmbeddedServices embeddedServices,
                                          WebSocketSessionRepository webSocketSessionRepository)

Default constructor.

Parameters:

embeddedServices - The embedded server services

webSocketSessionRepository - The websocket session repository

Method Detail

acceptInboundMessage

public boolean acceptInboundMessage(java.lang.Object msg)

Overrides:

acceptInboundMessage in class io.netty.channel.SimpleChannelInboundHandler<NettyHttpRequest<?>>

channelRead0

protected final void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                                  NettyHttpRequest<?> msg)

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<NettyHttpRequest<?>>

handleHandshake

protected io.netty.channel.ChannelFuture handleHandshake(io.netty.channel.ChannelHandlerContext ctx,
                                                         NettyHttpRequest req,
                                                         WebSocketBean<?> webSocketBean,
                                                         MutableHttpResponse<?> response)

Do the handshaking for WebSocket request.

Parameters:

ctx - The channel handler context

req - The request

webSocketBean - The web socket bean

response - The response

Returns:

The channel future

getWebSocketURL

protected java.lang.String getWebSocketURL(io.netty.channel.ChannelHandlerContext ctx,
                                           HttpRequest req)

Obtains the web socket URL.

Parameters:

ctx - The context

req - The request

Returns:

The socket URL