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