public class StatsChannelHandler
extends io.netty.channel.ChannelDuplexHandler
Modifier and Type | Field and Description |
---|---|
static io.netty.util.AttributeKey<Integer> |
bytesRead |
static io.netty.util.AttributeKey<Instant> |
startInstant |
Constructor and Description |
---|
StatsChannelHandler(org.infinispan.server.core.transport.NettyTransport transport) |
Modifier and Type | Method and Description |
---|---|
void |
channelActive(io.netty.channel.ChannelHandlerContext ctx) |
void |
channelRead(io.netty.channel.ChannelHandlerContext ctx,
Object msg) |
void |
write(io.netty.channel.ChannelHandlerContext ctx,
Object msg,
io.netty.channel.ChannelPromise promise) |
bind, close, connect, deregister, disconnect, flush, read
channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
public static io.netty.util.AttributeKey<Integer> bytesRead
public static io.netty.util.AttributeKey<Instant> startInstant
public StatsChannelHandler(org.infinispan.server.core.transport.NettyTransport transport)
public void channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg) throws Exception
channelRead
in interface io.netty.channel.ChannelInboundHandler
channelRead
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
public void channelActive(io.netty.channel.ChannelHandlerContext ctx) throws Exception
channelActive
in interface io.netty.channel.ChannelInboundHandler
channelActive
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.