@ChannelHandler.Sharable public class MessageMetricsChannelHandler extends AbstractChannelHandler<Object,Object>
| 限定符和类型 | 类和说明 |
|---|---|
static class |
MessageMetricsChannelHandler.MessageMetrics |
| 构造器和说明 |
|---|
MessageMetricsChannelHandler() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
close(io.netty.channel.ChannelHandlerContext ctx,
io.netty.channel.ChannelPromise promise) |
static MessageMetricsChannelHandler.MessageMetrics |
getOrSetMetrics(io.netty.channel.Channel channel) |
void |
onMessageReceived(io.netty.channel.ChannelHandlerContext ctx,
Object msg) |
channelRead, messageToString, userEventTriggered, writepublic static MessageMetricsChannelHandler.MessageMetrics getOrSetMetrics(io.netty.channel.Channel channel)
public void onMessageReceived(io.netty.channel.ChannelHandlerContext ctx,
Object msg)
throws Exception
ExceptionCopyright © 2023. All rights reserved.