diff --git a/http/http-advanced/src/test/java/io/quarkus/ts/http/advanced/DomainSocketIT.java b/http/http-advanced/src/test/java/io/quarkus/ts/http/advanced/DomainSocketIT.java index 6bcf8d73c4..1343db35a7 100644 --- a/http/http-advanced/src/test/java/io/quarkus/ts/http/advanced/DomainSocketIT.java +++ b/http/http-advanced/src/test/java/io/quarkus/ts/http/advanced/DomainSocketIT.java @@ -7,6 +7,7 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicReference; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Tag; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.condition.DisabledIfSystemProperty; @@ -25,6 +26,7 @@ import io.vertx.ext.web.client.predicate.ResponsePredicate; import io.vertx.ext.web.codec.BodyCodec; +@Disabled("https://github.com/quarkusio/quarkus/issues/33679") @QuarkusScenario @Tag("https://github.com/quarkusio/quarkus/issues/24739") @DisabledOnOs(value = OS.WINDOWS, disabledReason = "Netty Native Transport not supported on Windows, see https://quarkus.io/guides/vertx-reference#native-transport") diff --git a/http/vertx/src/test/java/io/quarkus/ts/vertx/AbstractVertxIT.java b/http/vertx/src/test/java/io/quarkus/ts/vertx/AbstractVertxIT.java index 7bc567a2fa..01f241cd67 100644 --- a/http/vertx/src/test/java/io/quarkus/ts/vertx/AbstractVertxIT.java +++ b/http/vertx/src/test/java/io/quarkus/ts/vertx/AbstractVertxIT.java @@ -12,7 +12,13 @@ import java.util.Map; import java.util.Objects; +import io.vertx.core.Vertx; +import io.vertx.core.http.HttpClient; +import io.vertx.core.http.HttpClientRequest; +import io.vertx.core.http.HttpClientResponse; +import io.vertx.core.http.HttpMethod; import org.apache.http.HttpStatus; +import org.hamcrest.MatcherAssert; import org.junit.jupiter.api.Test; import io.restassured.response.Response; @@ -41,6 +47,23 @@ public void httpServerParsing() { requests().get("/hello?name=you").then().statusCode(HttpStatus.SC_OK).body("content", is("Hello, you!")); } + @Test + public void httpClient() { + HttpClient httpClient = Vertx.vertx().createHttpClient(); + httpClient.request(HttpMethod.GET, "/hello") + .onComplete(httpClientRequestAsyncResult -> { + if (httpClientRequestAsyncResult.succeeded()) { + HttpClientRequest httpClientRequest = httpClientRequestAsyncResult.result(); + httpClientRequest.send() + .onComplete(httpClientResponseAsyncResult -> { + HttpClientResponse httpClientResponse = httpClientResponseAsyncResult.result(); + assertEquals(200, httpClientResponse.statusCode()); + MatcherAssert.assertThat(httpClientResponse.body(), is("Hello World!")); + }); + } + }); + } + public abstract RequestSpecification requests(); private Map parseMetrics(String body) {