本文整理了Java中javax.ws.rs.client.ClientBuilder.connectTimeout()
方法的一些代码示例,展示了ClientBuilder.connectTimeout()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ClientBuilder.connectTimeout()
方法的具体详情如下:
包路径:javax.ws.rs.client.ClientBuilder
类名称:ClientBuilder
方法名:connectTimeout
[英]Set the connect timeout.
Value 0 represents infinity. Negative values are not allowed.
[中]设置连接超时。
值0表示无穷大。不允许使用负值。
代码示例来源:origin: jbosstm/narayana
public void connectTimeout(long connect, TimeUnit unit) {
clientBuilder.connectTimeout(connect, unit);
if (client != null) {
client.close();
client = null;
}
}
代码示例来源:origin: org.talend.sdk.component/component-server-vault-proxy
private ClientBuilder createClient(final ExecutorService executor, final Optional<String> keystoreLocation,
final Optional<String> keystoreType, final String keystorePassword, final Optional<String> truststoreType,
final List<String> serverHostnames) {
final ClientBuilder builder = ClientBuilder.newBuilder();
builder.connectTimeout(connectTimeout, MILLISECONDS);
builder.readTimeout(readTimeout, MILLISECONDS);
builder.executorService(executor);
if (acceptAnyCertificate) {
builder.hostnameVerifier((host, session) -> true);
builder.sslContext(createUnsafeSSLContext());
} else if (keystoreLocation.isPresent()) {
builder.hostnameVerifier((host, session) -> serverHostnames.contains(host));
builder.sslContext(createSSLContext(keystoreLocation, keystoreType, keystorePassword, truststoreType));
}
providers
.map(it -> Stream.of(it.split(",")).map(String::trim).filter(v -> !v.isEmpty()))
.ifPresent(it -> it.forEach(builder::register));
return ClientTracingRegistrar.configure(builder);
}
代码示例来源:origin: org.talend.sdk.component/component-server-proxy
@Produces
@UiSpecProxy
@ApplicationScoped
public javax.ws.rs.client.Client client(final ProxyConfiguration configuration,
@UiSpecProxy final ExecutorService executor) {
final javax.ws.rs.client.Client client = ClientBuilder
.newBuilder()
.executorService(executor)
.property("executorService", executor) // rx()
.connectTimeout(configuration.getConnectTimeout(), MILLISECONDS)
.readTimeout(configuration.getReadTimeout(), MILLISECONDS)
.build();
ofNullable(configuration.getClientProviders()).ifPresent(list -> list.forEach(client::register));
return client;
}
内容来源于网络,如有侵权,请联系作者删除!