io.netty.channel.EventLoop.register()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(4.9k)|赞(0)|评价(0)|浏览(142)

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

EventLoop.register介绍

暂无

代码示例

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

@Deprecated
  @Override
  public ChannelFuture register(Channel channel, ChannelPromise promise) {
    return next().register(channel, promise);
  }
}

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

@Override
public ChannelFuture register(Channel channel) {
  return next().register(channel);
}

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

@Override
public ChannelFuture register(ChannelPromise promise) {
  return next().register(promise);
}

代码示例来源:origin: eclipse-vertx/vert.x

@Override
public ChannelFuture register(Channel channel) {
 return next().register(channel);
}

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

@Deprecated
  @Override
  public ChannelFuture register(Channel channel, ChannelPromise promise) {
    return next().register(channel, promise);
  }
}

代码示例来源:origin: eclipse-vertx/vert.x

@Override
public ChannelFuture register(Channel channel, ChannelPromise promise) {
 return next().register(channel, promise);
}

代码示例来源:origin: eclipse-vertx/vert.x

@Override
public ChannelFuture register(ChannelPromise promise) {
 return next().register(promise);
}

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

@Override
public ChannelFuture register(Channel channel) {
  return next().register(channel);
}

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

@Override
public ChannelFuture register(ChannelPromise promise) {
  return next().register(promise);
}

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

@Deprecated
@Override
public ChannelFuture register(Channel channel, ChannelPromise promise) {
  if (channel == null) {
    throw new NullPointerException("channel");
  }
  try {
    return nextChild().register(channel, promise);
  } catch (Throwable t) {
    promise.setFailure(t);
    return promise;
  }
}

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

@Deprecated
  @Override
  public ChannelFuture register(Channel channel, ChannelPromise promise) {
    return next().register(channel, promise);
  }
}

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

@Override
public ChannelFuture register(ChannelPromise promise) {
  try {
    return nextChild().register(promise);
  } catch (Throwable t) {
    promise.setFailure(t);
    return promise;
  }
}

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

@Deprecated
@Override
public ChannelFuture register(Channel channel, ChannelPromise promise) {
  if (channel == null) {
    throw new NullPointerException("channel");
  }
  try {
    return nextChild().register(channel, promise);
  } catch (Throwable t) {
    promise.setFailure(t);
    return promise;
  }
}

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

@Override
public ChannelFuture register(Channel channel) {
  if (channel == null) {
    throw new NullPointerException("channel");
  }
  try {
    EventLoop l = nextChild();
    return l.register(new DefaultChannelPromise(channel, l));
  } catch (Throwable t) {
    return new FailedChannelFuture(channel, GlobalEventExecutor.INSTANCE, t);
  }
}

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

@Override
public ChannelFuture register(ChannelPromise promise) {
  try {
    return nextChild().register(promise);
  } catch (Throwable t) {
    promise.setFailure(t);
    return promise;
  }
}

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

@Deprecated
@Override
public ChannelFuture register(Channel channel, ChannelPromise promise) {
  if (channel == null) {
    throw new NullPointerException("channel");
  }
  try {
    return nextChild().register(channel, promise);
  } catch (Throwable t) {
    promise.setFailure(t);
    return promise;
  }
}

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

@Override
public ChannelFuture register(Channel channel) {
  if (channel == null) {
    throw new NullPointerException("channel");
  }
  try {
    EventLoop l = nextChild();
    return l.register(new DefaultChannelPromise(channel, l));
  } catch (Throwable t) {
    return new FailedChannelFuture(channel, GlobalEventExecutor.INSTANCE, t);
  }
}

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

@Override
public ChannelFuture register(ChannelPromise promise) {
  try {
    return nextChild().register(promise);
  } catch (Throwable t) {
    promise.setFailure(t);
    return promise;
  }
}

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

@Override
public ChannelFuture register(Channel channel) {
  if (channel == null) {
    throw new NullPointerException("channel");
  }
  try {
    EventLoop l = nextChild();
    return l.register(new DefaultChannelPromise(channel, l));
  } catch (Throwable t) {
    return new FailedChannelFuture(channel, GlobalEventExecutor.INSTANCE, t);
  }
}

代码示例来源:origin: eclipse-vertx/vert.x

private DatagramSocketImpl(VertxInternal vertx, DatagramSocketOptions options) {
 Transport transport = vertx.transport();
 DatagramChannel channel = transport.datagramChannel(options.isIpV6() ? InternetProtocolFamily.IPv6 : InternetProtocolFamily.IPv4);
 transport.configure(channel, new DatagramSocketOptions(options));
 ContextInternal context = vertx.getOrCreateContext();
 channel.config().setOption(ChannelOption.DATAGRAM_CHANNEL_ACTIVE_ON_REGISTRATION, true);
 MaxMessagesRecvByteBufAllocator bufAllocator = channel.config().getRecvByteBufAllocator();
 bufAllocator.maxMessagesPerRead(1);
 context.nettyEventLoop().register(channel);
 if (options.getLogActivity()) {
  channel.pipeline().addLast("logging", new LoggingHandler());
 }
 VertxMetrics metrics = vertx.metricsSPI();
 this.metrics = metrics != null ? metrics.createDatagramSocketMetrics(options) : null;
 this.channel = channel;
 this.context = context;
 this.demand = Long.MAX_VALUE;
}

相关文章