@Override public void childChannelClosed(ChannelHandlerContext ctx, ChildChannelStateEvent e) throws Exception { super.childChannelClosed(ctx, e); LOG.info("Connection closed {}", e.getChildChannel().getRemoteAddress()); MessageDecoder.removeTransmitHistogram(e.getChildChannel()); }
@Override public void childChannelOpen(ChannelHandlerContext ctx, ChildChannelStateEvent e) throws Exception { allChannels.add(e.getChildChannel()); }
/** * Invoked when a child {@link Channel} was open. * (e.g. a server channel accepted a connection) */ void childChannelOpen(ChannelHandlerContext context, ChildChannelStateEvent event) throws Exception;
/** * Invoked when a child {@link Channel} was closed. * (e.g. the accepted connection was closed) */ void childChannelClosed(ChannelHandlerContext context, ChildChannelStateEvent event) throws Exception;
/** * Invoked when a child {@link Channel} was open. (e.g. a server channel * accepted a connection) */ public void childChannelOpen(ChannelHandlerContext ctx, ChildChannelStateEvent e) throws Exception { ctx.sendUpstream(e); }
/** * Invoked when a child {@link Channel} was closed. (e.g. the accepted * connection was closed) */ public void childChannelClosed(ChannelHandlerContext ctx, ChildChannelStateEvent e) throws Exception { ctx.sendUpstream(e); }