@Internal public class NettyServerWebSocketHandler extends AbstractNettyWebSocketHandler
WebSocketFrame
instances.Modifier and Type | Field and Description |
---|---|
static String |
ID
The id of the handler used when adding it to the Netty pipeline.
|
LOG, mediaTypeCodecRegistry, messageHandler, originatingRequest, session, uriVariables, webSocketBean, webSocketBinder, webSocketSessionRepository, webSocketVersion
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) |
channelRead0, exceptionCaught, getBodyArgument, getSession, handleWebSocketFrame, writeCloseFrameAndTerminate
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged
ensureNotSharable, handlerAdded, isSharable
public static final String ID
public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt) throws Exception
userEventTriggered
in interface io.netty.channel.ChannelInboundHandler
userEventTriggered
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
public boolean acceptInboundMessage(Object msg)
acceptInboundMessage
in class io.netty.channel.SimpleChannelInboundHandler<Object>
protected NettyRxWebSocketSession createWebSocketSession(io.netty.channel.ChannelHandlerContext ctx)
AbstractNettyWebSocketHandler
NettyRxWebSocketSession
.createWebSocketSession
in class AbstractNettyWebSocketHandler
ctx
- The contextprotected io.reactivex.Flowable<?> instrumentPublisher(io.netty.channel.ChannelHandlerContext ctx, Object result)
AbstractNettyWebSocketHandler
instrumentPublisher
in class AbstractNettyWebSocketHandler
ctx
- The contextresult
- The resultprotected Object invokeExecutable(BoundExecutable boundExecutable, MethodExecutionHandle<?,?> messageHandler)
AbstractNettyWebSocketHandler
invokeExecutable
in class AbstractNettyWebSocketHandler
boundExecutable
- The bound executablemessageHandler
- The message handlerprotected void messageHandled(io.netty.channel.ChannelHandlerContext ctx, NettyRxWebSocketSession session, Object message)
AbstractNettyWebSocketHandler
messageHandled
in class AbstractNettyWebSocketHandler
ctx
- The channel handler contextsession
- The sessionmessage
- The message that was handledpublic void handlerRemoved(io.netty.channel.ChannelHandlerContext ctx) throws Exception
handlerRemoved
in interface io.netty.channel.ChannelHandler
handlerRemoved
in class AbstractNettyWebSocketHandler
Exception