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

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

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

ClientBuilder.register介绍

暂无

代码示例

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

private static Client buildClient() {
  final ObjectMapper objectMapper = JsonMapper.INSTANCE.mapper;
  objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
  objectMapper.configure(DeserializationFeature.FAIL_ON_NULL_FOR_PRIMITIVES, false);
  objectMapper.registerModule(new Jdk8Module());
  final JacksonMessageBodyProvider jsonProvider = new JacksonMessageBodyProvider(objectMapper);
  return ClientBuilder.newBuilder().register(jsonProvider).build();
 }
}

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

public static void main(String[] args) {
  try {
    System.out.println("\"Hello World\" Jersey OpenTracing Example App");
    prepare();
    final ResourceConfig resourceConfig = new ResourceConfig(TracedResource.class,
        OpenTracingFeature.class,
        ReqFilterA.class, ReqFilterB.class,
        RespFilterA.class, RespFilterB.class);
    final HttpServer server = GrizzlyHttpServerFactory.createHttpServer(BASE_URI, resourceConfig, false);
    Runtime.getRuntime().addShutdownHook(new Thread(server::shutdownNow));
    server.start();
    System.out.println(String.format("Application started.\nTry out %s/application.wadl\n"
        + "Stop the application using CTRL+C", BASE_URI));
    // do the first "example" request with tracing-enabled client to show something in Jaegger UI,
    // include some weird headers and accepted types, that will be visible in the span's tags
    Client client = ClientBuilder.newBuilder().register(OpenTracingFeature.class).build();
    client.target(BASE_URI).path("resource/managedClient").request()
        .accept("text/plain", "application/json", "*/*")
        .header("foo", "bar")
        .header("foo", "baz")
        .header("Hello", "World").get();
    Thread.currentThread().join();
  } catch (IOException | InterruptedException ex) {
    Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
  }
}

代码示例来源:origin: oracle/helidon

.register(basicAuth)
.build();

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

/**
 * A helper method for creating clients. The client will be created using
 * the given configuration and security context. Additionally, the client
 * will be automatically configured for JSON serialization/deserialization.
 *
 * @param config client configuration
 * @param ctx    security context, which may be null for non-secure client
 *               creation
 * @return a Client instance
 */
private static Client createClientHelper(final ClientConfig config, final SSLContext ctx) {
  ClientBuilder clientBuilder = ClientBuilder.newBuilder();
  if (config != null) {
    clientBuilder = clientBuilder.withConfig(config);
  }
  if (ctx != null) {
    // Apache http DefaultHostnameVerifier that checks subject alternative names against the hostname of the URI
    clientBuilder = clientBuilder.sslContext(ctx).hostnameVerifier(new DefaultHostnameVerifier());
  }
  clientBuilder = clientBuilder.register(ObjectMapperResolver.class).register(JacksonJaxbJsonProvider.class);
  return clientBuilder.build();
}

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

@SuppressWarnings("unused") // Part of public API
public static Client buildClient() {
 final ObjectMapper objectMapper = JsonMapper.INSTANCE.mapper;
 objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, true);
 objectMapper.configure(DeserializationFeature.FAIL_ON_NULL_FOR_PRIMITIVES, true);
 objectMapper.registerModule(new Jdk8Module());
 final JacksonMessageBodyProvider jsonProvider = new JacksonMessageBodyProvider(objectMapper);
 return ClientBuilder.newBuilder().register(jsonProvider).build();
}

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

.register(filterFeature)
.register(JacksonFeature.class)
.build();

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

@BeforeClass
public static void setup() throws IOException {
 httpServer = GrizzlyHttpServerFactory.createHttpServer(
   SERVER_URI,
   createResourceConfig(),
   false);
 httpServer.start();
 client = ClientBuilder.newBuilder()
   .register(GsonMessageBodyProvider.class)
   .register(PURE_GSON_TEXT_PLAIN)
   .build();
}

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

clientBuilder.register(new ClientRequestFilter() { // Can we do it better, without filter?
  @Override
  public void filter(ClientRequestContext requestContext) {
clientBuilder.register(new GZipEncoder());
clientBuilder.register(new Jersey2EurekaIdentityHeaderFilter(identity));

代码示例来源:origin: signalapp/Signal-Server

private static Client initializeClient(DirectoryServerConfiguration directoryServerConfiguration)
  throws CertificateException
{
 KeyStore   trustStore = initializeKeyStore(directoryServerConfiguration.getReplicationCaCertificate());
 SSLContext sslContext = SslConfigurator.newInstance()
                     .securityProtocol("TLSv1.2")
                     .trustStore(trustStore)
                     .createSSLContext();
 return ClientBuilder.newBuilder()
           .register(HttpAuthenticationFeature.basic("signal", directoryServerConfiguration.getReplicationPassword().getBytes()))
           .sslContext(sslContext)
           .build();
}

代码示例来源:origin: dadoonet/fscrawler

@BeforeClass
public static void startRestClient() {
  // create the client
  client = ClientBuilder.newBuilder()
      .register(MultiPartFeature.class)
      .register(RestJsonProvider.class)
      .register(JacksonFeature.class)
      .build();
  target = client.target("http://127.0.0.1:" + testRestPort + "/fscrawler");
}

代码示例来源:origin: com.github.jmnarloch/spring-jax-rs-client-proxy

/**
   * Registers the provider classes.
   *
   * @param clientBuilder the client builder
   * @param providers     the providers classes
   */
  private void registerProviders(ClientBuilder clientBuilder, Class<?>[] providers) {

    for (Class<?> filter : providers) {
      clientBuilder.register(filter);
    }
  }
}

代码示例来源:origin: org.apache.geronimo/geronimo-opentracing-common

@Override
public ClientBuilder configure(final ClientBuilder builder, final ExecutorService executorService) {
  if (builder.getConfiguration().getInstances().stream().anyMatch(it -> requestFilter == it)) {
    return builder;
  }
  return builder.register(requestFilter).register(responseFilter)
      .executorService(wrapExecutor(executorService));
}

代码示例来源:origin: allegro/hermes

private <T> T createProxy(String url, Class<T> endpoint, ClientConfig clientConfig) {
  ClientBuilder clientBuilder = getClientBuilder(clientConfig);
  for (ClientRequestFilter filter : filters) {
    clientBuilder.register(filter);
  }
  return WebResourceFactory.newResource(endpoint, clientBuilder.build().target(url));
}

代码示例来源:origin: org.apache.camel/camel-bonita

public static BonitaAPI build(BonitaAPIConfig bonitaAPIConfig) {
  if (bonitaAPIConfig == null) {
    throw new IllegalArgumentException("bonitaApiConfig is null");
  }
  ClientBuilder clientBuilder = ClientBuilder.newBuilder();
  clientBuilder.register(JacksonJsonProvider.class);
  Client client = clientBuilder.build();
  client.register(new BonitaAuthFilter(bonitaAPIConfig));
  WebTarget webTarget = client.target(bonitaAPIConfig.getBaseBonitaURI()).path("/API/bpm");
  return new BonitaAPI(bonitaAPIConfig, webTarget);
}

代码示例来源:origin: io.thorntail/microprofile-opentracing

public ClientBuilder configure(ClientBuilder clientBuilder, ExecutorService executorService) {
  ResteasyClientBuilder resteasyClientBuilder = (ResteasyClientBuilder)clientBuilder;
  Tracer tracer = CDI.current().select(Tracer.class).get();
  return resteasyClientBuilder.executorService(new TracedExecutorService(executorService, tracer))
   .register(new Builder(tracer)
     .withTraceSerialization(false)
     .build());
 }
}

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

@Before
public void setUp() throws Exception {
 InetSocketAddress address = testBase.getTestingCluster().getConfiguration().getSocketAddrVar(ConfVars.REST_SERVICE_ADDRESS);
 restServiceURI = new URI("http", null, address.getHostName(), address.getPort(), "/rest", null, null);
 clusterURI = new URI(restServiceURI + "/cluster");
 restClient = ClientBuilder.newBuilder()
   .register(new GsonFeature(PlanGsonHelper.registerAdapters()))
   .register(LoggingFilter.class)
   .property(ClientProperties.FEATURE_AUTO_DISCOVERY_DISABLE, true)
   .property(ClientProperties.METAINF_SERVICES_LOOKUP_DISABLE, true)
   .build();
}

代码示例来源:origin: dremio/dremio-oss

protected static void initClient(final String hostname) {
 client = ClientBuilder.newBuilder()
   .trustStore(currentDremioDaemon.getWebServer().getTrustStore())
   .register(MultiPartFeature.class)
   .build();
 apiV2 = client
   .target(String.format("https://%s:%d", hostname, currentDremioDaemon.getWebServer().getPort()))
   .path("apiv2");
}

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

@SuppressWarnings("rawtypes")
@Test
public void testGenericInvocationCallback() throws Exception {
  InvocationCallback<?> callback = createGenericInvocationCallback();
  String address = "http://localhost:" + PORT + "/bookstore/books/check/123";
  ClientBuilder.newBuilder().register(new BookServerAsyncClient.BooleanReaderWriter())
    .build().target(address)
    .request().accept("text/boolean").async().get(callback).get();
  assertTrue(((GenericInvocationCallback)callback).getResult().readEntity(Boolean.class));
}

相关文章