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;
}