类io.netty.channel.pool.ChannelHealthChecker源码实例Demo

下面列出了怎么用io.netty.channel.pool.ChannelHealthChecker的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: azure-cosmosdb-java   文件: RntbdRequestManager.java
public RntbdRequestManager(final ChannelHealthChecker healthChecker, final int pendingRequestLimit) {

        checkArgument(pendingRequestLimit > 0, "pendingRequestLimit: %s", pendingRequestLimit);
        checkNotNull(healthChecker, "healthChecker");

        this.pendingRequests = new ConcurrentHashMap<>(pendingRequestLimit);
        this.pendingRequestLimit = pendingRequestLimit;
        this.healthChecker = healthChecker;
    }
 
源代码2 项目: riposte   文件: StreamingAsyncHttpClient.java
@Override
public Future<Boolean> isHealthy(Channel channel) {
    // See if we've marked the channel as being non-usable first.
    if (channelIsMarkedAsBeingBroken(channel))
        return channel.eventLoop().newSucceededFuture(Boolean.FALSE);

    // We haven't marked it broken, so fallback to the default channel health checker.
    return ChannelHealthChecker.ACTIVE.isHealthy(channel);
}
 
RntbdClientChannelHandler(final Config config, final ChannelHealthChecker healthChecker) {
    checkNotNull(healthChecker, "expected non-null healthChecker");
    checkNotNull(config, "expected non-null config");
    this.healthChecker = healthChecker;
    this.config = config;
}
 
public ConnectionlessChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler, ChannelHealthChecker healthCheck) {
    super(bootstrap, handler, healthCheck);
}
 
public ConnectionlessChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler, ChannelHealthChecker healthCheck, boolean releaseHealthCheck) {
    super(bootstrap, handler, healthCheck, releaseHealthCheck);
}
 
 类所在包
 类方法
 同包方法