@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, pongHandler, subProtocol, uriVariables, webSocketBean, webSocketBinder, webSocketSessionRepository, webSocketVersion
Modifier and Type | Method and Description |
---|---|
boolean |
acceptInboundMessage(Object msg) |
protected NettyWebSocketSession |
createWebSocketSession(io.netty.channel.ChannelHandlerContext ctx)
Subclasses should implement to create the actual
NettyWebSocketSession . |
Argument<?> |
getBodyArgument() |
Argument<?> |
getPongArgument() |
NettyWebSocketSession |
getSession() |
void |
handlerRemoved(io.netty.channel.ChannelHandlerContext ctx) |
protected Publisher<?> |
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,
Object message)
Method called once a message has been handled by the handler.
|
void |
userEventTriggered(io.netty.channel.ChannelHandlerContext ctx,
Object evt) |
callOpenMethod, channelRead0, exceptionCaught, forwardErrorToUser, handleCloseReason, handleWebSocketFrame, writeCloseFrameAndTerminate
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged
ensureNotSharable, handlerAdded, isSharable
public static final String ID
public NettyWebSocketSession getSession()
getSession
in class AbstractNettyWebSocketHandler
public Argument<?> getBodyArgument()
getBodyArgument
in class AbstractNettyWebSocketHandler
public Argument<?> getPongArgument()
getPongArgument
in class AbstractNettyWebSocketHandler
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 NettyWebSocketSession createWebSocketSession(io.netty.channel.ChannelHandlerContext ctx)
AbstractNettyWebSocketHandler
NettyWebSocketSession
.createWebSocketSession
in class AbstractNettyWebSocketHandler
ctx
- The contextprotected Publisher<?> 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, Object message)
AbstractNettyWebSocketHandler
messageHandled
in class AbstractNettyWebSocketHandler
ctx
- The channel handler contextmessage
- 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