com.ning.http.client.AsyncHttpClientConfig.getRequestTimeout()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(6.1k)|赞(0)|评价(0)|浏览(106)

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

AsyncHttpClientConfig.getRequestTimeout介绍

[英]Return the maximum time in millisecond an com.ning.http.client.AsyncHttpClient waits until the response is completed.
[中]

代码示例

代码示例来源:origin: com.ning/async-http-client

void touchConnection(final Connection c, final Request request) {
  final long timeOut = request.getRequestTimeout() > 0
      ? request.getRequestTimeout()
      : clientConfig.getRequestTimeout();
  
  
  if (timeOut > 0) {
    if (resolver != null) {
      resolver.setTimeoutMillis(c,
          System.currentTimeMillis() + timeOut);
    }
  }
}

代码示例来源:origin: com.ning/async-http-client

public static int requestTimeout(AsyncHttpClientConfig config, Request request) {
  return request.getRequestTimeout() != 0 ? request.getRequestTimeout() : config.getRequestTimeout();
}

代码示例来源:origin: com.ning/async-http-client

proxyServerSelector = prototype.getProxyServerSelector();
realm = prototype.getRealm();
requestTimeout = prototype.getRequestTimeout();
sslContext = prototype.getSSLContext();
userAgent = prototype.getUserAgent();

代码示例来源:origin: javaee/grizzly-ahc

public static int requestTimeout(AsyncHttpClientConfig config, Request request) {
  return request.getRequestTimeout() != 0 ? request.getRequestTimeout() : config.getRequestTimeout();
}

代码示例来源:origin: org.glassfish.grizzly/grizzly-http-client

public static int requestTimeout(AsyncHttpClientConfig config, Request request) {
  return request.getRequestTimeout() != 0 ? request.getRequestTimeout() : config.getRequestTimeout();
}

代码示例来源:origin: io.gatling/async-http-client

public static int requestTimeout(AsyncHttpClientConfig config, Request request) {
  return request.getRequestTimeout() != 0 ? request.getRequestTimeout() : config.getRequestTimeout();
}

代码示例来源:origin: org.glassfish.grizzly/grizzly-http-client

void touchConnection(final Connection c, final Request request) {
  final long timeOut = request.getRequestTimeout() > 0
      ? request.getRequestTimeout()
      : clientConfig.getRequestTimeout();
  
  
  if (timeOut > 0) {
    if (resolver != null) {
      resolver.setTimeoutMillis(c,
          System.currentTimeMillis() + timeOut);
    }
  }
}

代码示例来源:origin: javaee/grizzly-ahc

void touchConnection(final Connection c, final Request request) {
  final long timeOut = request.getRequestTimeout() > 0
      ? request.getRequestTimeout()
      : clientConfig.getRequestTimeout();
  
  
  if (timeOut > 0) {
    if (resolver != null) {
      resolver.setTimeoutMillis(c,
          System.currentTimeMillis() + timeOut);
    }
  }
}

代码示例来源:origin: io.gatling/async-http-client

void touchConnection(final Connection c, final Request request) {
  final long perRequestTimeout = request.getRequestTimeout();
  if (perRequestTimeout > 0) {
    final long newTimeout = System.currentTimeMillis() + perRequestTimeout;
    if (resolver != null) {
      resolver.setTimeoutMillis(c, newTimeout);
    }
  } else {
    final long timeout = clientConfig.getRequestTimeout();
    if (timeout > 0) {
      if (resolver != null) {
        resolver.setTimeoutMillis(c, System.currentTimeMillis() + timeout);
      }
    }
  }
}

代码示例来源:origin: com.ning/async-http-client

fcb.add(new TransportFilter());
final int timeout = clientConfig.getRequestTimeout();
if (timeout > 0) {
  int delay = 500;

代码示例来源:origin: Nike-Inc/riposte

private void verifyDefaultUnderlyingClientConfig(AsyncHttpClientHelper instance) {
  AsyncHttpClientConfig config = instance.asyncHttpClient.getConfig();
  assertThat(config.isAllowPoolingConnections()).isTrue();
  assertThat(config.getMaxRequestRetry()).isEqualTo(0);
  assertThat(config.getRequestTimeout()).isEqualTo(DEFAULT_REQUEST_TIMEOUT_MILLIS);
  assertThat(config.getConnectionTTL()).isEqualTo(DEFAULT_POOLED_DOWNSTREAM_CONNECTION_TTL_MILLIS);
  assertThat(Whitebox.getInternalState(instance.asyncHttpClient, "signatureCalculator")).isNull();
}

代码示例来源:origin: spotify/async-google-pubsub-client

log.debug("connect timeout: {}", config.getConnectTimeout());
log.debug("read timeout: {}", config.getReadTimeout());
log.debug("request timeout: {}", config.getRequestTimeout());
log.debug("max connections: {}", config.getMaxConnections());
log.debug("max connections per host: {}", config.getMaxConnectionsPerHost());

代码示例来源:origin: Nike-Inc/riposte

@DataProvider(value = {
  "true",
  "false"
}, splitBy = "\\|")
@Test
public void kitchen_sink_constructor_sets_up_underlying_client_with_expected_config(boolean performSubspan) {
  // given
  int customRequestTimeoutVal = 4242;
  AsyncHttpClientConfig config =
    new AsyncHttpClientConfig.Builder().setRequestTimeout(customRequestTimeoutVal).build();
  AsyncHttpClientConfig.Builder builderMock = mock(AsyncHttpClientConfig.Builder.class);
  doReturn(config).when(builderMock).build();
  // when
  AsyncHttpClientHelper instance = new AsyncHttpClientHelper(builderMock, performSubspan);
  // then
  assertThat(instance.performSubSpanAroundDownstreamCalls).isEqualTo(performSubspan);
  assertThat(instance.asyncHttpClient.getConfig()).isSameAs(config);
  assertThat(instance.asyncHttpClient.getConfig().getRequestTimeout()).isEqualTo(customRequestTimeoutVal);
}

代码示例来源:origin: org.glassfish.grizzly/grizzly-http-client

proxyServerSelector = prototype.getProxyServerSelector();
realm = prototype.getRealm();
requestTimeout = prototype.getRequestTimeout();
sslContext = prototype.getSSLContext();
userAgent = prototype.getUserAgent();

代码示例来源:origin: io.gatling/async-http-client

proxyServerSelector = prototype.getProxyServerSelector();
realm = prototype.getRealm();
requestTimeout = prototype.getRequestTimeout();
sslContext = prototype.getSSLContext();
userAgent = prototype.getUserAgent();

代码示例来源:origin: javaee/grizzly-ahc

proxyServerSelector = prototype.getProxyServerSelector();
realm = prototype.getRealm();
requestTimeout = prototype.getRequestTimeout();
sslContext = prototype.getSSLContext();
userAgent = prototype.getUserAgent();

代码示例来源:origin: io.gatling/async-http-client

fcb.add(new TransportFilter());
final int timeout = clientConfig.getRequestTimeout();
if (timeout > 0) {
  int delay = 500;

代码示例来源:origin: org.glassfish.grizzly/grizzly-http-client

fcb.add(new TransportFilter());
final int timeout = clientConfig.getRequestTimeout();
if (timeout > 0) {
  int delay = 500;

代码示例来源:origin: javaee/grizzly-ahc

fcb.add(new TransportFilter());
final int timeout = clientConfig.getRequestTimeout();
if (timeout > 0) {
  int delay = 500;

相关文章

微信公众号

最新文章

更多