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

Constructor Summary

Constructors

Constructor and Description
NettyServerWebSocketUpgradeHandler(WebSocketSessionRepository webSocketSessionRepository, Router router, RequestBinderRegistry binderRegistry, WebSocketBeanRegistry webSocketBeanRegistry, MediaTypeCodecRegistry mediaTypeCodecRegistry, ApplicationEventPublisher eventPublisher) 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

Constructor Detail

NettyServerWebSocketUpgradeHandler

public NettyServerWebSocketUpgradeHandler(WebSocketSessionRepository webSocketSessionRepository,
                                          Router router,
                                          RequestBinderRegistry binderRegistry,
                                          WebSocketBeanRegistry webSocketBeanRegistry,
                                          MediaTypeCodecRegistry mediaTypeCodecRegistry,
                                          ApplicationEventPublisher eventPublisher)

Default constructor.

Parameters:

webSocketSessionRepository - The websocket sessions repository

router - The router

binderRegistry - the request binder registry

webSocketBeanRegistry - The web socket bean register

mediaTypeCodecRegistry - The codec registry

eventPublisher - The event publisher

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