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