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

Channel.deregister介绍

暂无

代码示例

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

@Override
public ChannelGroupFuture deregister(ChannelMatcher matcher) {
  if (matcher == null) {
    throw new NullPointerException("matcher");
  }
  Map<Channel, ChannelFuture> futures =
      new LinkedHashMap<Channel, ChannelFuture>(size());
  for (Channel c: serverChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  for (Channel c: nonServerChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  return new DefaultChannelGroupFuture(this, futures, executor);
}

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

@Override
public ChannelGroupFuture deregister(ChannelMatcher matcher) {
  if (matcher == null) {
    throw new NullPointerException("matcher");
  }
  Map<Channel, ChannelFuture> futures =
      new LinkedHashMap<Channel, ChannelFuture>(size());
  for (Channel c: serverChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  for (Channel c: nonServerChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  return new DefaultChannelGroupFuture(this, futures, executor);
}

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

@Override
public ChannelGroupFuture deregister(ChannelMatcher matcher) {
  if (matcher == null) {
    throw new NullPointerException("matcher");
  }
  Map<Channel, ChannelFuture> futures =
      new LinkedHashMap<Channel, ChannelFuture>(size());
  for (Channel c: serverChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  for (Channel c: nonServerChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  return new DefaultChannelGroupFuture(this, futures, executor);
}

代码示例来源：origin: aadnk/ProtocolLib

@Override
@Deprecated
public ChannelFuture deregister() {
  return delegate.deregister();
}

代码示例来源：origin: aadnk/ProtocolLib

@Override
@Deprecated
public ChannelFuture deregister(ChannelPromise paramChannelPromise) {
  return delegate.deregister(paramChannelPromise);
}

代码示例来源：origin: kpavlov/jreactive-8583

@SuppressWarnings("WeakerAccess")
  public void stop() {
    final Channel channel = getChannel();
    if (channel == null) {
      throw new IllegalStateException("Server is not started.");
    }
    logger.info("Stopping the Server...");
    try {
      channel.deregister();
      channel.close().sync().await(10, TimeUnit.SECONDS);
      logger.info("Server was Stopped.");
    } catch (InterruptedException e) {
      logger.error("Error while stopping the server", e);
    }

  }
}

代码示例来源：origin: apache/activemq-artemis

@Override
public ChannelGroupFuture deregister(ChannelMatcher matcher) {
  if (matcher == null) {
    throw new NullPointerException("matcher");
  }
  Map<Channel, ChannelFuture> futures =
      new LinkedHashMap<Channel, ChannelFuture>(size());
  for (Channel c: serverChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  for (Channel c: nonServerChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  return new DefaultChannelGroupFuture(this, futures, executor);
}

代码示例来源：origin: org.jboss.eap/wildfly-client-all

@Override
public ChannelGroupFuture deregister(ChannelMatcher matcher) {
  if (matcher == null) {
    throw new NullPointerException("matcher");
  }
  Map<Channel, ChannelFuture> futures =
      new LinkedHashMap<Channel, ChannelFuture>(size());
  for (Channel c: serverChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  for (Channel c: nonServerChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  return new DefaultChannelGroupFuture(this, futures, executor);
}

代码示例来源：origin: org.apache.activemq/artemis-jms-client-all

@Override
public ChannelGroupFuture deregister(ChannelMatcher matcher) {
  if (matcher == null) {
    throw new NullPointerException("matcher");
  }
  Map<Channel, ChannelFuture> futures =
      new LinkedHashMap<Channel, ChannelFuture>(size());
  for (Channel c: serverChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  for (Channel c: nonServerChannels.values()) {
    if (matcher.matches(c)) {
      futures.put(c, c.deregister());
    }
  }
  return new DefaultChannelGroupFuture(this, futures, executor);
}

代码示例来源：origin: org.wso2.transport.http/org.wso2.transport.http.netty

@Override
public void onSuccess(String protocol, ChannelFuture channelFuture) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Created the connection to address: {}",
         route.toString() + " " + "Original Channel ID is : " + channelFuture.channel().id());
  }
  if (srcHandler != null) {
    channelFuture.channel().deregister().addListener(future ->
        srcHandler.getEventLoop().register(channelFuture.channel()).addListener(
            future1 -> startExecutingOutboundRequest(protocol, channelFuture)));
  } else {
    startExecutingOutboundRequest(protocol, channelFuture);
  }
}

代码示例来源：origin: io.ratpack/ratpack-core

@Override
public void connect(final Downstream<? super T> downstream) throws Exception {
 channelPool.acquire().addListener(acquireFuture -> {
  if (acquireFuture.isSuccess()) {
   Channel channel = (Channel) acquireFuture.getNow();
   if (channel.eventLoop().equals(execution.getEventLoop())) {
    send(downstream, channel);
   } else {
    channel.deregister().addListener(deregisterFuture ->
     execution.getEventLoop().register(channel).addListener(registerFuture -> {
      if (registerFuture.isSuccess()) {
       send(downstream, channel);
      } else {
       channel.close();
       channelPool.release(channel);
       connectFailure(downstream, registerFuture.cause());
      }
     })
    );
   }
  } else {
   connectFailure(downstream, acquireFuture.cause());
  }
 });
}