Java源码示例:org.jboss.resteasy.client.jaxrs.internal.ResteasyClientBuilderImpl
示例1
/**
* Configures and constructs a Resteasy client to use for calling the Alfresco Public ReST API in the dockerised deployment.
*
* @return the configured client
*/
protected static ResteasyClient setupResteasyClient()
{
final SimpleModule module = new SimpleModule();
module.setDeserializerModifier(new RestAPIBeanDeserializerModifier());
final ResteasyJackson2Provider resteasyJacksonProvider = new ResteasyJackson2Provider();
final ObjectMapper mapper = new ObjectMapper();
mapper.setSerializationInclusion(Include.NON_EMPTY);
mapper.registerModule(module);
resteasyJacksonProvider.setMapper(mapper);
final LocalResteasyProviderFactory resteasyProviderFactory = new LocalResteasyProviderFactory(new ResteasyProviderFactoryImpl());
resteasyProviderFactory.register(resteasyJacksonProvider);
// will cause a warning regarding Jackson provider which is already registered
RegisterBuiltin.register(resteasyProviderFactory);
resteasyProviderFactory.register(new MultiValuedParamConverterProvider());
final ResteasyClient client = new ResteasyClientBuilderImpl().providerFactory(resteasyProviderFactory).build();
return client;
}
示例2
@Test
public void testZMSClientReadTimeoutForRestEasyContainer() throws Exception {
ZMSClientExt.setClientBuilder(new ResteasyClientBuilderImpl());
server = new JettyServer(port);
server.start();
String baseUri = "http://localhost:" + port;
ZMSClientExt zmsClient = new ZMSClientExt(baseUri);
try {
zmsClient.getDomain("test");
fail("read timeout not set");
} catch (ZMSClientException expected) {
assertEquals(expected.code, ZMSClientException.BAD_REQUEST);
assertEquals(
expected.getMessage(),
"ResourceException (400): RESTEASY004655: Unable to invoke request: java.net.SocketTimeoutException: Read timed out");
}
zmsClient.close();
ZMSClientExt.setClientBuilder(null);
}
示例3
@Test
public void testZTSClientReadTimeoutForRestEasyContainer() throws Exception {
ZTSClientMock.setClientBuilder(new ResteasyClientBuilderImpl());
server = new JettyServer(port);
server.start();
String baseUri = "http://localhost:" + port;
ZTSClientMock ztsClient = new ZTSClientMock(baseUri);
try {
ztsClient.getRoleAccess("testDomain", "testPrincipal");
fail("read timeout not set");
} catch (ZTSClientException expected) {
assertEquals(expected.code, ZTSClientException.BAD_REQUEST);
assertEquals(
expected.getMessage(),
"ResourceException (400): RESTEASY004655: Unable to invoke request: java.net.SocketTimeoutException: Read timed out");
}
ztsClient.close();
ZTSClientMock.setClientBuilder(null);
}
示例4
@BuildStep
ReflectiveClassBuildItem reflect() {
return ReflectiveClassBuildItem.builder(ResteasyClientBuilderImpl.class, JacksonProvider.class, ProxyBuilderImpl.class,
StringListMapDeserializer.class,
StringOrArrayDeserializer.class,
StringOrArraySerializer.class)
.constructors(true)
.methods(true)
.build();
}
示例5
@Substitute
public static ClientBuilder newBuilder() {
ResteasyClientBuilder client = new ResteasyClientBuilderImpl();
client.providerFactory(new LocalResteasyProviderFactory(RestClientRecorder.providerFactory));
return client;
}