本文整理了Java中io.netty.channel.EventLoop.register()
方法的一些代码示例,展示了EventLoop.register()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。EventLoop.register()
方法的具体详情如下:
包路径:io.netty.channel.EventLoop
类名称: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;
}
内容来源于网络,如有侵权,请联系作者删除!