io.netty.channel.ChannelHandlerContext#fireChannelUnregistered ( )源码实例Demo

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
    LOGGER.info("channel out! ----> {}", ctx.channel());
    ChannelId channelId = ctx.channel().id();
    RTUChannelInfo channelInfo = GlobalInfo.CHANNEL_INFO_MAP.remove(channelId);
    GlobalInfo.SN_CHANNEL_INFO_MAP.remove(channelInfo.getSn());
    LOGGER.info("remove channel: {}", channelInfo);
    ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
    if (logger.isEnabled(internalLevel)) {
        logger.log(internalLevel, format(ctx, "UNREGISTERED"));
    }
    ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
    LOGGER.info("channel out! ----> {}", ctx.channel());
    ChannelId channelId = ctx.channel().id();
    RTUChannelInfo channelInfo = GlobalInfo.CHANNEL_INFO_MAP.remove(channelId);
    GlobalInfo.SN_CHANNEL_INFO_MAP.remove(channelInfo.getSn());
    LOGGER.info("remove channel: {}", channelInfo);
    ctx.fireChannelUnregistered();
}
 

/**
 * The {@link Channel} of the {@link ChannelHandlerContext} was unregistered from its {@link EventLoop}
 *
 * @param context {@link ChannelHandlerContext} to which this {@link RntbdRequestManager} belongs
 */
@Override
public void channelUnregistered(final ChannelHandlerContext context) {

    this.traceOperation(context, "channelUnregistered");

    if (!this.closingExceptionally) {
        this.completeAllPendingRequestsExceptionally(context, ON_CHANNEL_UNREGISTERED);
    } else {
        logger.debug("{} channelUnregistered exceptionally", context);
    }

    context.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
    if (logger.isEnabled(internalLevel)) {
        logger.log(internalLevel, format(ctx, "UNREGISTERED"));
    }
    ctx.fireChannelUnregistered();
}
 

public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
    ctx.fireChannelUnregistered();
}
 

public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
    LOG.error("################RxtxClientHandler channelUnregistered: " + ctx.channel().id());
    ctx.fireChannelUnregistered();
}
 

public void channelUnregistered(ChannelHandlerContext ctx) {
    ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) {
  failAndResetUserPromise(new ClosedChannelException());
  ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(final ChannelHandlerContext ctx) throws Exception {
    ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
  Gdx.app.debug(TAG, "channelUnregistered");
  ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
  if (DEBUG_CALLS) Gdx.app.debug(TAG, "channelUnregistered");
  ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
  Gdx.app.debug(TAG, "channelUnregistered");
  ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
  if (DEBUG_CALLS) Gdx.app.debug(TAG, "channelUnregistered");
  ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
    ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
    ctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext nettyctx) throws Exception {
    nettyctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext nettyctx) throws Exception {
    log.debug("channelUnregistered().");
    
    nettyctx.fireChannelUnregistered();
}
 

@Override
public void channelUnregistered(ChannelHandlerContext ctx) {
  failAndResetUserPromise(new ClosedChannelException());
  ctx.fireChannelUnregistered();
}