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

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

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

Client.getConfiguration介绍

暂无

代码示例

代码示例来源:origin: jersey/jersey

NettyConnector(Client client) {
  final Object threadPoolSize = client.getConfiguration().getProperties().get(ClientProperties.ASYNC_THREADPOOL_SIZE);
  if (threadPoolSize != null && threadPoolSize instanceof Integer && (Integer) threadPoolSize > 0) {
    executorService = Executors.newFixedThreadPool((Integer) threadPoolSize);
  } else {
    executorService = Executors.newCachedThreadPool();
  }
  this.group = new NioEventLoopGroup();
  this.client = client;
}

代码示例来源:origin: jersey/jersey

private Client configureClient(Client client) {
  if (client == null) {
    client = ClientBuilder.newClient();
  }
  final Configuration config = client.getConfiguration();
  if (!config.isRegistered(AuthCodeGrantImpl.DefaultTokenMessageBodyReader.class)) {
    client.register(AuthCodeGrantImpl.DefaultTokenMessageBodyReader.class);
  }
  if (!config.isRegistered(JacksonFeature.class)) {
    client.register(JacksonFeature.class);
  }
  return client;
}

代码示例来源:origin: Netflix/eureka

@Override
  public void run() {
    Stopwatch start = executionTimeStats.start();
    try {
      HttpClientConnectionManager cm = (HttpClientConnectionManager) apacheHttpClient
          .getConfiguration()
          .getProperty(ApacheClientProperties.CONNECTION_MANAGER);
      cm.closeIdleConnections(connectionIdleTimeout, TimeUnit.SECONDS);
    } catch (Throwable e) {
      s_logger.error("Cannot clean connections", e);
      cleanupFailed.increment();
    } finally {
      if (null != start) {
        start.stop();
      }
    }
  }
}

代码示例来源:origin: jersey/jersey

private OAuth1AuthorizationFlowImpl(final OAuth1Parameters params, final OAuth1Secrets secrets, final String requestTokenUri,
                  final String accessTokenUri, final String authorizationUri, final String callbackUri,
                  final Client client, final boolean enableLogging) {
  this.parameters = params;
  this.secrets = secrets;
  this.requestTokenUri = requestTokenUri;
  this.accessTokenUri = accessTokenUri;
  this.authorizationUri = authorizationUri;
  if (client != null) {
    this.client = client;
  } else {
    this.client = ClientBuilder.newBuilder().build();
  }
  final Configuration config = this.client.getConfiguration();
  if (enableLogging && !config.isRegistered(LoggingFeature.class)) {
    this.client.register(new LoggingFeature(LOGGER, LoggingFeature.Verbosity.PAYLOAD_ANY));
  }
  if (!config.isRegistered(OAuth1ClientFeature.class)) {
    this.client.register(new OAuth1ClientFeature(params, secrets));
  }
  if (callbackUri != null) {
    this.parameters.callback(callbackUri);
  }
  if (secrets.getConsumerSecret() == null || parameters.getConsumerKey() == null) {
    throw new IllegalStateException(LocalizationMessages.ERROR_CONFIGURATION_MISSING_CONSUMER());
  }
}

代码示例来源:origin: yammer/tenacity

@Override
public Configuration getConfiguration() {
  return delegate.getConfiguration();
}

代码示例来源:origin: smoketurner/dropwizard-consul

@Override
public Configuration getConfiguration() {
 return delegate.getConfiguration();
}

代码示例来源:origin: com.yammer.tenacity/tenacity-core

@Override
public Configuration getConfiguration() {
  return delegate.getConfiguration();
}

代码示例来源:origin: net.oneandone.reactive/reactive-http

@Override
public Configuration getConfiguration() {
  return client.getConfiguration();
}

代码示例来源:origin: eclipse-ee4j/glassfish

@Override
public Configuration getConfiguration() {
  return realClient.getConfiguration();
}

代码示例来源:origin: grro/stability

@Override
public Configuration getConfiguration() {
  return client.getConfiguration();
}

代码示例来源:origin: usnistgov/iheos-toolkit2

/**
 * This will initialize the SPI to contact the test engine at
 * http://hostname:port/xdstools2
 * @param urlRoot URL Root - http://hostname:port/xdstools2 for example
 */
public EngineSpi(String urlRoot) {
  ClientConfig cc = new ClientConfig().register(new JacksonFeature());
  Client c = ClientBuilder.newClient(cc);
  c.register(new LoggingFilter(java.util.logging.Logger.getLogger("SYSTEM"), true));
  Configuration conf = c.getConfiguration();
  logger.info(conf.getPropertyNames());
  logger.info("target is " + urlRoot + "/rest/");
  target = c.target(urlRoot + "/rest/");
}

代码示例来源:origin: com.eclipsesource.jaxrs/jersey-all

private Client configureClient(Client client) {
  if (client == null) {
    client = ClientBuilder.newClient();
  }
  final Configuration config = client.getConfiguration();
  if (!config.isRegistered(AuthCodeGrantImpl.DefaultTokenMessageBodyReader.class)) {
    client.register(AuthCodeGrantImpl.DefaultTokenMessageBodyReader.class);
  }
  if (!config.isRegistered(JacksonFeature.class)) {
    client.register(JacksonFeature.class);
  }
  return client;
}

代码示例来源:origin: hstaudacher/osgi-jax-rs-connector

private Client configureClient(Client client) {
  if (client == null) {
    client = ClientBuilder.newClient();
  }
  final Configuration config = client.getConfiguration();
  if (!config.isRegistered(AuthCodeGrantImpl.DefaultTokenMessageBodyReader.class)) {
    client.register(AuthCodeGrantImpl.DefaultTokenMessageBodyReader.class);
  }
  if (!config.isRegistered(JacksonFeature.class)) {
    client.register(JacksonFeature.class);
  }
  return client;
}

代码示例来源:origin: org.glassfish.jersey.security/oauth2-client

private Client configureClient(Client client) {
  if (client == null) {
    client = ClientBuilder.newClient();
  }
  final Configuration config = client.getConfiguration();
  if (!config.isRegistered(AuthCodeGrantImpl.DefaultTokenMessageBodyReader.class)) {
    client.register(AuthCodeGrantImpl.DefaultTokenMessageBodyReader.class);
  }
  if (!config.isRegistered(JacksonFeature.class)) {
    client.register(JacksonFeature.class);
  }
  return client;
}

代码示例来源:origin: apache/cxf

@Override
  public void filter(ClientRequestContext context) throws IOException {
    String prop = context.getClient().getConfiguration().getProperty("clientproperty").toString();
    String prop2 = context.getConfiguration().getProperty("clientproperty").toString();
    if (!prop2.equals(prop) || !"somevalue".equals(prop2)) {
      throw new RuntimeException();
    }
  }
}

代码示例来源:origin: com.netflix.eureka/eureka-client-jersey2

@Override
  public void run() {
    Stopwatch start = executionTimeStats.start();
    try {
      HttpClientConnectionManager cm = (HttpClientConnectionManager) apacheHttpClient
          .getConfiguration()
          .getProperty(ApacheClientProperties.CONNECTION_MANAGER);
      cm.closeIdleConnections(connectionIdleTimeout, TimeUnit.SECONDS);
    } catch (Throwable e) {
      s_logger.error("Cannot clean connections", e);
      cleanupFailed.increment();
    } finally {
      if (null != start) {
        start.stop();
      }
    }
  }
}

代码示例来源:origin: com.eclipsesource.jaxrs/consumer

/**
 * <p>
 * Creates a consumer object out of a <code>@Path</code> interface. It will create a proxy object of the interface
 * that calls the specified service using the passed in base url. The de/serialization is done using the passed in
 * <code>@Provider</code> objects. The passed in {@link Client} will be used to send requests.
 * </p>
 *
 * @param baseUrl The server url hosting the specified service.
 * @param client The {@link Client} to use for sending requests
 * @param type The <code>@Path</code> annotated interface class object.
 * @param customProvider An array of <code>@Provider</code> object for de/serialization.
 * @return a proxy object for the passed in type.
 */
@SuppressWarnings( "unchecked" )
public static <T> T createConsumer( String baseUrl, Client client, Class<T> type ) {
 checkUrl( baseUrl );
 checkType( type );
 checkClient( client );
 checkAnnotation( type );
 ensureTypeIsAnInterface( type );
 Path path = type.getAnnotation( Path.class );
 ensureMultiPartFeature( client.getConfiguration(), type );
 return ( T )Proxy.newProxyInstance( type.getClassLoader(),
                   new Class<?>[] { type },
                   createHandler( baseUrl, client, path ) );
}

代码示例来源:origin: hstaudacher/osgi-jax-rs-connector

private OAuth1AuthorizationFlowImpl(final OAuth1Parameters params, final OAuth1Secrets secrets, final String requestTokenUri,
                  final String accessTokenUri, final String authorizationUri, final String callbackUri,
                  final Client client, final boolean enableLogging) {
  this.parameters = params;
  this.secrets = secrets;
  this.requestTokenUri = requestTokenUri;
  this.accessTokenUri = accessTokenUri;
  this.authorizationUri = authorizationUri;
  if (client != null) {
    this.client = client;
  } else {
    this.client = ClientBuilder.newBuilder().build();
  }
  final Configuration config = this.client.getConfiguration();
  if (enableLogging && !config.isRegistered(LoggingFilter.class)) {
    this.client.register(new LoggingFilter(LOGGER, true));
  }
  if (!config.isRegistered(OAuth1ClientFeature.class)) {
    this.client.register(new OAuth1ClientFeature(params, secrets));
  }
  if (callbackUri != null) {
    this.parameters.callback(callbackUri);
  }
  if (secrets.getConsumerSecret() == null || parameters.getConsumerKey() == null) {
    throw new IllegalStateException(LocalizationMessages.ERROR_CONFIGURATION_MISSING_CONSUMER());
  }
}

代码示例来源:origin: org.glassfish.jersey.security/oauth1-client

private OAuth1AuthorizationFlowImpl(final OAuth1Parameters params, final OAuth1Secrets secrets, final String requestTokenUri,
                  final String accessTokenUri, final String authorizationUri, final String callbackUri,
                  final Client client, final boolean enableLogging) {
  this.parameters = params;
  this.secrets = secrets;
  this.requestTokenUri = requestTokenUri;
  this.accessTokenUri = accessTokenUri;
  this.authorizationUri = authorizationUri;
  if (client != null) {
    this.client = client;
  } else {
    this.client = ClientBuilder.newBuilder().build();
  }
  final Configuration config = this.client.getConfiguration();
  if (enableLogging && !config.isRegistered(LoggingFeature.class)) {
    this.client.register(new LoggingFeature(LOGGER, LoggingFeature.Verbosity.PAYLOAD_ANY));
  }
  if (!config.isRegistered(OAuth1ClientFeature.class)) {
    this.client.register(new OAuth1ClientFeature(params, secrets));
  }
  if (callbackUri != null) {
    this.parameters.callback(callbackUri);
  }
  if (secrets.getConsumerSecret() == null || parameters.getConsumerKey() == null) {
    throw new IllegalStateException(LocalizationMessages.ERROR_CONFIGURATION_MISSING_CONSUMER());
  }
}

代码示例来源:origin: com.eclipsesource.jaxrs/jersey-all

private OAuth1AuthorizationFlowImpl(final OAuth1Parameters params, final OAuth1Secrets secrets, final String requestTokenUri,
                  final String accessTokenUri, final String authorizationUri, final String callbackUri,
                  final Client client, final boolean enableLogging) {
  this.parameters = params;
  this.secrets = secrets;
  this.requestTokenUri = requestTokenUri;
  this.accessTokenUri = accessTokenUri;
  this.authorizationUri = authorizationUri;
  if (client != null) {
    this.client = client;
  } else {
    this.client = ClientBuilder.newBuilder().build();
  }
  final Configuration config = this.client.getConfiguration();
  if (enableLogging && !config.isRegistered(LoggingFilter.class)) {
    this.client.register(new LoggingFilter(LOGGER, true));
  }
  if (!config.isRegistered(OAuth1ClientFeature.class)) {
    this.client.register(new OAuth1ClientFeature(params, secrets));
  }
  if (callbackUri != null) {
    this.parameters.callback(callbackUri);
  }
  if (secrets.getConsumerSecret() == null || parameters.getConsumerKey() == null) {
    throw new IllegalStateException(LocalizationMessages.ERROR_CONFIGURATION_MISSING_CONSUMER());
  }
}

相关文章