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

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

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

Client.register介绍

暂无

代码示例

代码示例来源：origin: dropwizard/dropwizard

/**
 * Builds the {@link Client} instance with a custom reactive client provider.
 *
 * @return a fully-configured {@link Client}
 */
public <RX extends RxInvokerProvider<?>> Client buildRx(String name, Class<RX> invokerType) {
  return build(name).register(invokerType);
}

代码示例来源：origin: confluentinc/ksql

public void setupAuthenticationCredentials(final String userName, final String password) {
 final HttpAuthenticationFeature feature = HttpAuthenticationFeature.basic(
   Objects.requireNonNull(userName),
   Objects.requireNonNull(password)
 );
 client.register(feature);
}

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

@Override
public Client getAuthorizedClient() {
  return ClientBuilder.newClient().register(getOAuth2Feature());
}

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

@Override
public Client getAuthorizedClient() {
  return ClientBuilder.newClient().register(getOAuth1Feature());
}

代码示例来源：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: traccar/traccar

public static void init(IdentityManager testIdentityManager) {
  config = new Config();
  objectMapper = new ObjectMapper();
  objectMapper.registerModule(new JSR353Module());
  client = ClientBuilder.newClient().register(new ObjectMapperContextResolver());
  identityManager = testIdentityManager;
}

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

@Override
  public void run() {
    final Client resourceClient = ClientBuilder.newClient();
    resourceClient.register(new MoxyJsonFeature());
    final WebTarget messageStreamResource = resourceClient.target(App.getApiUri()).path("message/stream");
    Message message = null;
    try {
      while (!cancelled && (message = messages.take()) != null) {
        msgListener.onMessage(message);
        final Response r = messageStreamResource.request().put(Entity.json(message));
        if (r.getStatusInfo().getFamily() != Response.Status.Family.SUCCESSFUL) {
          LOGGER.warning("Unexpected PUT message response status code: " + r.getStatus());
        }
      }
      if (message == null) {
        LOGGER.info("Timed out while waiting for a message.");
      }
    } catch (InterruptedException ex) {
      LOGGER.log(Level.WARNING, "Waiting for a message has been interrupted.", ex);
    } finally {
      readerHandle.cancel(true);
      msgListener.onComplete();
    }
  }
});

代码示例来源：origin: dropwizard/dropwizard

private Client build(String name, ExecutorService threadPool,
           ObjectMapper objectMapper,
           Validator validator) {
  if (!configuration.isGzipEnabled()) {
    apacheHttpClientBuilder.disableContentCompression(true);
  }
  final Client client = ClientBuilder.newClient(buildConfig(name, threadPool, objectMapper, validator));
  client.register(new JerseyIgnoreRequestUserAgentHeaderFilter());
  // Tie the client to server lifecycle
  if (environment != null) {
    environment.lifecycle().manage(new Managed() {
      @Override
      public void start() throws Exception {
      }
      @Override
      public void stop() throws Exception {
        client.close();
      }
    });
  }
  if (configuration.isGzipEnabled()) {
    client.register(new GZipDecoder());
    client.register(new ConfiguredGZipEncoder(configuration.isGzipEnabledForRequests()));
  }
  return client;
}

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

@Override
public void start(final String keywords, final DataListener msgListener) {
  msgListener.onStart();
  running = true;
  final Random rnd = new Random();
  final String aggregatorPrefix = getPrefix();
  Executors.newSingleThreadExecutor().submit(() -> {
    final Client resourceClient = ClientBuilder.newClient();
    resourceClient.register(new MoxyJsonFeature());
    final WebTarget messageStreamResource = resourceClient.target(App.getApiUri()).path(getPath());
    try {
      while (running) {
        final Message message = new Message(
            aggregatorPrefix + " " + MESSAGES[rnd.nextInt(MESSAGES.length)],
            rgbColor,
            IMG_URI);
        msgListener.onMessage(message);
        final Response r = messageStreamResource.request().put(Entity.json(message));
        if (r.getStatusInfo().getFamily() != Response.Status.Family.SUCCESSFUL) {
          LOGGER.warning("Unexpected PUT message response status code: " + r.getStatus());
        }
        Thread.sleep(rnd.nextInt(1000) + 750);
      }
      msgListener.onComplete();
    } catch (Throwable t) {
      LOGGER.log(Level.WARNING, "Waiting for a message has been interrupted.", t);
      msgListener.onError();
    }
  });
}

代码示例来源：origin: aol/micro-server

protected Client initClient(int rt, int ct) {
  ClientConfig clientConfig = new ClientConfig();
  clientConfig.property(ClientProperties.CONNECT_TIMEOUT, ct);
  clientConfig.property(ClientProperties.READ_TIMEOUT, rt);
  ClientBuilder.newBuilder().register(JacksonFeature.class);
  Client client = ClientBuilder.newClient(clientConfig);
  client.register(JacksonFeature.class);
  JacksonJaxbJsonProvider provider = new JacksonJaxbJsonProvider();
  provider.setMapper(JacksonUtil.getMapper());
  client.register(provider);
  return client;
}

代码示例来源：origin: aol/micro-server

protected Client initClient(int rt, int ct) {
  ClientConfig clientConfig = new ClientConfig();
  clientConfig.property(ClientProperties.CONNECT_TIMEOUT, ct);
  clientConfig.property(ClientProperties.READ_TIMEOUT, rt);
  ClientBuilder.newBuilder().register(JacksonFeature.class);
  Client client = ClientBuilder.newClient(clientConfig);
  client.register(JacksonFeature.class);
  JacksonJaxbJsonProvider provider = new JacksonJaxbJsonProvider();
  provider.setMapper(JacksonUtil.getMapper());
  client.register(provider);
  return client;
}

代码示例来源：origin: apache/hbase

@Override
public void setConf(Configuration conf) {
 super.setConf(conf);
 if (conf == null) {
  // Configured gets passed null before real conf. Why? I don't know.
  return;
 }
 serverHostname = conf.get(REST_API_CLUSTER_MANAGER_HOSTNAME, DEFAULT_SERVER_HOSTNAME);
 serverUsername = conf.get(REST_API_CLUSTER_MANAGER_USERNAME, DEFAULT_SERVER_USERNAME);
 serverPassword = conf.get(REST_API_CLUSTER_MANAGER_PASSWORD, DEFAULT_SERVER_PASSWORD);
 clusterName = conf.get(REST_API_CLUSTER_MANAGER_CLUSTER_NAME, DEFAULT_CLUSTER_NAME);
 // Add filter to Client instance to enable server authentication.
 client.register(HttpAuthenticationFeature.basic(serverUsername, serverPassword));
}

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

jerseyApacheClient.register(new Jersey2DynamicGZIPContentEncodingFilter(config));
jerseyApacheClient.register(new EurekaIdentityHeaderFilter(identity));

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

.register(new MoxyJsonFeature())
.register(HttpAuthenticationFeature.basic(App.getTwitterUserName(), App.getTwitterUserPassword()))
.register(GZipEncoder.class);

代码示例来源：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: jersey/jersey

/**
 * Get a builder that can be directly used to perform Authorization Code Grant flow defined by
 * Facebook documentation.
 *
 * @param clientIdentifier Client identifier.
 * @param redirectUri Redirect URI
 * @param client Client instance that should be used to perform Access token request.
 * @return Builder instance.
 */
public static OAuth2CodeGrantFlow.Builder getFacebookAuthorizationBuilder(ClientIdentifier clientIdentifier,
                                     String redirectUri, Client client) {
  final AuthCodeGrantImpl.Builder builder = new AuthCodeGrantImpl.Builder();
  builder.accessTokenUri("https://graph.facebook.com/oauth/access_token");
  builder.authorizationUri("https://www.facebook.com/dialog/oauth");
  builder.redirectUri(redirectUri);
  builder.clientIdentifier(clientIdentifier);
  client.register(FacebookTokenMessageBodyReader.class);
  builder.client(client);
  return builder;
}

代码示例来源：origin: hugegraph/hugegraph

public RestClient(String url) {
  this.client = ClientBuilder.newClient();
  this.client.register(EncodingFilter.class);
  this.client.register(GZipEncoder.class);
  this.target = this.client.target(url);
}

代码示例来源：origin: traccar/traccar

client = ClientBuilder.newClient().register(new ObjectMapperContextResolver());

代码示例来源：origin: stackoverflow.com

private static final String BASE_URI = "http://localhost:" + PORT;
@Test(groups = "functionalTests")
public void testGetTenant() throws Exception {
  Client client = ClientBuilder.newClient();
  ResteasyWebTarget target = (ResteasyWebTarget)client.target(BASE_URI);
  client.register(new AddAuthHeadersRequestFilter("root", "DefaultPasswordsAre:-("));
  TenantResource resource = target.proxy(TenantResource.class);

  RestTenant restTenant = resource.getTenant(tenant.id().value().toString());

  assertThat(restTenant.getName(), is("test-tenant"));
  assertThat(restTenant.isActive(), is(true));
}

代码示例来源：origin: jamesagnew/hapi-fhir

public synchronized Client getNativeClientClient() {
  if (myNativeClient == null) {
    ClientBuilder builder = ClientBuilder.newBuilder();
    myNativeClient = builder.build();
  }
if (registeredComponents != null && !registeredComponents.isEmpty()) {
 for (Class<?> c : registeredComponents) {
  myNativeClient = myNativeClient.register(c);
 }
}
  return myNativeClient;
}

内容来源于网络，如有侵权，请联系作者删除！

Client

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com