diff options
Diffstat (limited to 'rest-services/http-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/adapters/http/RxHttpClientIT.java')
-rw-r--r-- | rest-services/http-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/adapters/http/RxHttpClientIT.java | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/rest-services/http-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/adapters/http/RxHttpClientIT.java b/rest-services/http-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/adapters/http/RxHttpClientIT.java index 8d076e02..ff4f0297 100644 --- a/rest-services/http-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/adapters/http/RxHttpClientIT.java +++ b/rest-services/http-client/src/test/java/org/onap/dcaegen2/services/sdk/rest/services/adapters/http/RxHttpClientIT.java @@ -26,6 +26,7 @@ import io.vavr.Tuple; import io.vavr.collection.HashSet; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.Test; +import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.config.ImmutableConnectionPoolConfig; import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.config.ImmutableRetryConfig; import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.config.ImmutableRxHttpClientConfig; import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.exceptions.HttpException; @@ -336,6 +337,28 @@ class RxHttpClientIT { assertNoRetry(); } + @Test + void simpleGetWithCustomConnectionPool() throws Exception { + // given + final HttpRequest httpRequest = requestFor("/sample-get") + .method(HttpMethod.GET) + .build(); + final RxHttpClient cut = RxHttpClientFactory.create(ImmutableRxHttpClientConfig.builder() + .connectionPool(defaultConnectionPoolConfig()) + .build()); + + // when + final Mono<String> bodyAsString = cut.call(httpRequest) + .doOnNext(HttpResponse::throwIfUnsuccessful) + .map(HttpResponse::bodyAsString); + + // then + StepVerifier.create(bodyAsString) + .expectNext("OK") + .expectComplete() + .verify(TIMEOUT); + } + private ImmutableHttpRequest.Builder requestFor(String path) throws MalformedURLException { return ImmutableHttpRequest.builder() .url(new URL("http", HTTP_SERVER.host(), HTTP_SERVER.port(), path).toString()); @@ -367,4 +390,13 @@ class RxHttpClientIT { private void assert400(HttpResponse httpResponse) { assertThat(httpResponse.statusCode()).isEqualTo(400); } + + private ImmutableConnectionPoolConfig defaultConnectionPoolConfig(){ + return ImmutableConnectionPoolConfig + .builder() + .connectionPool(1) + .maxIdleTime(Duration.ofSeconds(5)) + .maxLifeTime(Duration.ofSeconds(10)) + .build(); + } } |