Java 类org.jboss.netty.channel.ChildChannelStateEvent 实例源码

项目:jstrom    文件:StormServerHandler.java   
@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());
}
项目:jstorm    文件:StormServerHandler.java   
@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());
}
项目:httptunnel    文件:HttpTunnelServerChannelHandler.java   
@Override
public void childChannelOpen(ChannelHandlerContext ctx, ChildChannelStateEvent e) throws Exception {
    allChannels.add(e.getChildChannel());
}
项目:netty-isdn-transport    文件:IStateMachineChannelHandler.java   
/**
 * Invoked when a child {@link Channel} was open.
 * (e.g. a server channel accepted a connection)
 */
void childChannelOpen(ChannelHandlerContext context, ChildChannelStateEvent event) throws Exception;
项目:netty-isdn-transport    文件:IStateMachineChannelHandler.java   
/**
 * Invoked when a child {@link Channel} was closed.
 * (e.g. the accepted connection was closed)
 */
void childChannelClosed(ChannelHandlerContext context, ChildChannelStateEvent event) throws Exception;
项目:netty-isdn-transport    文件:SimpleStateMachineHandler.java   
/**
 * 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);
}
项目:netty-isdn-transport    文件:SimpleStateMachineHandler.java   
/**
 * 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);
}