本文整理了Java中org.jboss.netty.channel.Channel.disconnect()方法的一些代码示例，展示了Channel.disconnect()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Channel.disconnect()方法的具体详情如下：
包路径：org.jboss.netty.channel.Channel
类名称：Channel
方法名：disconnect

Channel.disconnect介绍

[英]Disconnects this channel from the current remote address asynchronously.
[中]异步断开此通道与当前远程地址的连接。

代码示例

代码示例来源：origin: io.netty/netty

public ChannelGroupFuture disconnect() {
  Map<Integer, ChannelFuture> futures =
    new LinkedHashMap<Integer, ChannelFuture>(size());
  for (Channel c: serverChannels.values()) {
    futures.put(c.getId(), c.disconnect().awaitUninterruptibly());
  }
  for (Channel c: nonServerChannels.values()) {
    futures.put(c.getId(), c.disconnect());
  }
  return new DefaultChannelGroupFuture(this, futures);
}

代码示例来源：origin: bristleback/bristleback

@Override
public void stop() {
 channel.disconnect();
}

代码示例来源：origin: com.thimbleware.jmemcached/jmemcached-core

protected void handleQuit(Channel channel) {
  channel.disconnect();
}

代码示例来源：origin: org.onosproject/onos-of-ctl

/**
 * log an error message for a duplicate dpid and disconnect this channel.
 * @param h the IO channel for this switch.
 */
protected void disconnectDuplicate(OFChannelHandler h) {
  log.error("Duplicated dpid or incompleted cleanup - "
      + "disconnecting channel {}", h.getSwitchInfoString());
  h.duplicateDpidFound = Boolean.TRUE;
  h.channel.disconnect();
}

代码示例来源：origin: org.onosproject/onos-pcep-controller-impl

protected void disconnectDuplicate(PcepChannelHandler h) {
  log.error("Duplicated Pcc IP or incompleted cleanup - " + "disconnecting channel {}",
      h.getClientInfoString());
  h.duplicatePccIdFound = Boolean.TRUE;
  h.channel.disconnect();
}

代码示例来源：origin: org.onosproject/onos-protocols-pcep-ctl

protected void disconnectDuplicate(PcepChannelHandler h) {
  log.error("Duplicated Pcc IP or incompleted cleanup - " + "disconnecting channel {}",
      h.getClientInfoString());
  h.duplicatePccIdFound = Boolean.TRUE;
  h.channel.disconnect();
}

代码示例来源：origin: fjfd/microscope

public Deferred<Object> execute(final TSDB tsdb, final Channel chan,
                  final String[] cmd) {
    chan.disconnect();
    return Deferred.fromResult(null);
  }
}

代码示例来源：origin: org.onosproject/onos-of-ctl

/**
 * Log an OpenFlow error message from a switch and disconnect the
 * channel.
 *
 * @param h the IO channel for this switch.
 * @param error The error message
 */
protected void logErrorDisconnect(OFChannelHandler h, OFErrorMsg error) {
  logError(h, error);
  log.error("Disconnecting switch {}", h.getSwitchInfoString());
  h.channel.disconnect();
}

代码示例来源：origin: kangfoo/nettyDefinitiveGuide

public void disconnect() {
  if (channel.isConnected()) {
    channel.disconnect();
  }
}

代码示例来源：origin: bristleback/bristleback

@Override
 protected void channelIdle(ChannelHandlerContext ctx, IdleState state, long lastActivityTimeMillis) throws Exception {
  ctx.getChannel().disconnect();
 }
}

代码示例来源：origin: oldmanpushcart/excavator

/**
 * --
 */
public void dec() {
  if (0 >= counter.decrementAndGet()
      && null != channel) {
    channel.disconnect();
    channel.close();
  }
}

代码示例来源：origin: os-libera/OpenVirteX

@Override
void processOFError(final SwitchChannelHandler h, final OFError m)
    throws IOException {
  h.log.error(
      "Error waiting for desc stats reply (type:{}, code:{})",
      m.getErrorType(), m.getErrorCode());
  h.channel.disconnect();
}

代码示例来源：origin: os-libera/OpenVirteX

@Override
void processOFError(final SwitchChannelHandler h, final OFError m) {
  h.log.error("Error waiting for Hello (type:{}, code:{})",
      m.getErrorType(), m.getErrorCode());
  h.channel.disconnect();
}

代码示例来源：origin: os-libera/OpenVirteX

@Override
void processOFError(final ControllerChannelHandler h,
    final OFError m) throws IOException {
  h.log.error("Error waiting for Hello (type:{}, code:{})",
      m.getErrorType(), m.getErrorCode());
  h.channel.disconnect();
}

代码示例来源：origin: os-libera/OpenVirteX

@Override
void processOFError(final SwitchChannelHandler h, final OFError m)
    throws IOException {
  h.log.error(
      "Error waiting for config reply (type:{}, code:{})",
      m.getErrorType(), m.getErrorCode());
  h.channel.disconnect();
}

代码示例来源：origin: os-libera/OpenVirteX

@Override
void processOFError(final ControllerChannelHandler h,
    final OFError m) throws IOException {
  h.log.error(
      "Error waiting for Features Request (type:{}, code:{})",
      m.getErrorType(), m.getErrorCode());
  h.channel.disconnect();
}

代码示例来源：origin: k3po/k3po

@Override
  public void operationComplete(ChannelFuture future) throws Exception {
    ChannelFuture disconnect = transport.disconnect();
    chainFutures(disconnect, evt.getFuture());
  }
});

代码示例来源：origin: k3po/k3po

@Override
  public void operationComplete(ChannelFuture future) throws Exception {
    ChannelFuture disconnect = transport.disconnect();
    chainFutures(disconnect, evt.getFuture());
  }
});

代码示例来源：origin: org.apache.camel/camel-netty

@Override
protected void doSuspend() throws Exception {
  if (channel != null) {
    LOG.debug("ServerBootstrap disconnecting from {}:{}", configuration.getHost(), configuration.getPort());
    channel.disconnect().sync();
    channel = null;
  }
}

代码示例来源：origin: os-libera/OpenVirteX

@Override
public void tearDown() {
  PhysicalSwitch.log.info("Switch disconnected {} ",
      this.featuresReply.getDatapathId());
  this.statsMan.stop();
  this.channel.disconnect();
  this.map.removePhysicalSwitch(this);
}