javax.ws.rs.client.ClientBuilder.readTimeout()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(2.4k)|赞(0)|评价(0)|浏览(154)

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

ClientBuilder.readTimeout介绍

[英]Set the read timeout.

The value is the timeout to read a response. If the server doesn't respond within the defined timeframe, ProcessingException is thrown with TimeoutException as a cause.

Value 0 represents infinity. Negative values are not allowed.
[中]设置读取超时。
该值是读取响应的超时时间。如果服务器未在定义的时间范围内响应,则会引发ProcessingException,并将TimeoutException作为原因。
值0表示无穷大。不允许使用负值。

代码示例

代码示例来源:origin: jbosstm/narayana

public void readTimeout(long read, TimeUnit unit) {
  clientBuilder.readTimeout(read, 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;
}

相关文章