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