io.micronaut.http.client.websocket

Class NettyWebSocketClientHandler<T>

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.client.websocket.NettyWebSocketClientHandler<T>

Type Parameters:

T - The type emitted.

All Implemented Interfaces:

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

@Internal
public class NettyWebSocketClientHandler<T>
extends AbstractNettyWebSocketHandler

Handler for WebSocket clients.

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 inherited from class io.micronaut.http.netty.websocket.AbstractNettyWebSocketHandler

ID, LOG, mediaTypeCodecRegistry, messageHandler, session, uriVariables, webSocketBinder, webSocketSessionRepository, webSocketVersion

Constructor Summary

Constructors

Constructor and Description
NettyWebSocketClientHandler(MutableHttpRequest<?> request, WebSocketBean<T> webSocketBean, io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker, RequestBinderRegistry requestBinderRegistry, MediaTypeCodecRegistry mediaTypeCodecRegistry, io.reactivex.FlowableEmitter<T> emitter) Default constructor.

Method Summary

Modifier and Type	Method and Description
void	channelActive(io.netty.channel.ChannelHandlerContext ctx)
protected void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, Object msg)
protected 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	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
void	userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)

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

handlerRemoved, handleWebSocketFrame, instrumentPublisher, invokeExecutable, messageHandled, writeCloseFrameAndTerminate

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyWebSocketClientHandler

public NettyWebSocketClientHandler(MutableHttpRequest<?> request,
                                   WebSocketBean<T> webSocketBean,
                                   io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker,
                                   RequestBinderRegistry requestBinderRegistry,
                                   MediaTypeCodecRegistry mediaTypeCodecRegistry,
                                   io.reactivex.FlowableEmitter<T> emitter)

Default constructor.

Parameters:

request - The originating request that created the WebSocket.

webSocketBean - The WebSocket client bean.

handshaker - The handshaker

requestBinderRegistry - The request binder registry

mediaTypeCodecRegistry - The media type codec registry

emitter - The socket emitter

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

getBodyArgument

public Argument<?> getBodyArgument()

Overrides:

getBodyArgument in class AbstractNettyWebSocketHandler

Returns:

The body argument for the message handler

getSession

public NettyRxWebSocketSession getSession()

Overrides:

getSession in class AbstractNettyWebSocketHandler

Returns:

The session

handlerAdded

public void handlerAdded(io.netty.channel.ChannelHandlerContext ctx)

Specified by:

handlerAdded in interface io.netty.channel.ChannelHandler

Overrides:

handlerAdded in class io.netty.channel.ChannelHandlerAdapter

channelActive

public void channelActive(io.netty.channel.ChannelHandlerContext ctx)

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

channelRead0

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

Overrides:

channelRead0 in class AbstractNettyWebSocketHandler

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

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 AbstractNettyWebSocketHandler