java类org.jboss.netty.channel.ChildChannelStateEvent的实例源码-面圈网

StormServerHandler.java 文件源码项目：jstrom 阅读 25 收藏 0 点赞 0 评论 0

@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());
}

StormServerHandler.java 文件源码项目：jstorm 阅读 33 收藏 0 点赞 0 评论 0

@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());
}

HttpTunnelServerChannelHandler.java 文件源码项目：httptunnel 阅读 33 收藏 0 点赞 0 评论 0

@Override
public void childChannelOpen(ChannelHandlerContext ctx, ChildChannelStateEvent e) throws Exception {
    allChannels.add(e.getChildChannel());
}

IStateMachineChannelHandler.java 文件源码项目：netty-isdn-transport 阅读 33 收藏 0 点赞 0 评论 0

/**
 * Invoked when a child {@link Channel} was open.
 * (e.g. a server channel accepted a connection)
 */
void childChannelOpen(ChannelHandlerContext context, ChildChannelStateEvent event) throws Exception;

IStateMachineChannelHandler.java 文件源码项目：netty-isdn-transport 阅读 34 收藏 0 点赞 0 评论 0

/**
 * Invoked when a child {@link Channel} was closed.
 * (e.g. the accepted connection was closed)
 */
void childChannelClosed(ChannelHandlerContext context, ChildChannelStateEvent event) throws Exception;

SimpleStateMachineHandler.java 文件源码项目：netty-isdn-transport 阅读 31 收藏 0 点赞 0 评论 0

/**
 * 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);
}

SimpleStateMachineHandler.java 文件源码项目：netty-isdn-transport 阅读 34 收藏 0 点赞 0 评论 0

/**
 * 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);
}