You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by zb...@apache.org on 2021/04/30 12:18:20 UTC
[camel-quarkus] 11/12: Adapt MicroProfile Health to Camel 3.10
This is an automated email from the ASF dual-hosted git repository.
zbendhiba pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit abd99c0c12cc512412dc297fb63fefe0bfa34f41
Author: James Netherton <ja...@gmail.com>
AuthorDate: Fri Apr 30 09:46:44 2021 +0100
Adapt MicroProfile Health to Camel 3.10
Fixes #2521
---
.../it/health/MicroProfileHealthTest.java | 63 ++++++++++------------
.../it/health/MicroprofileHealthIT.java | 2 -
2 files changed, 28 insertions(+), 37 deletions(-)
diff --git a/integration-tests/microprofile/src/test/java/org/apache/camel/quarkus/component/microprofile/it/health/MicroProfileHealthTest.java b/integration-tests/microprofile/src/test/java/org/apache/camel/quarkus/component/microprofile/it/health/MicroProfileHealthTest.java
index 2e728bd..b8d2834 100644
--- a/integration-tests/microprofile/src/test/java/org/apache/camel/quarkus/component/microprofile/it/health/MicroProfileHealthTest.java
+++ b/integration-tests/microprofile/src/test/java/org/apache/camel/quarkus/component/microprofile/it/health/MicroProfileHealthTest.java
@@ -24,30 +24,27 @@ import io.restassured.RestAssured;
import io.restassured.http.ContentType;
import io.restassured.path.json.JsonPath;
import org.awaitility.Awaitility;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import static org.hamcrest.Matchers.containsInAnyOrder;
import static org.hamcrest.Matchers.containsString;
import static org.hamcrest.Matchers.is;
-@Disabled("https://github.com/apache/camel-quarkus/issues/2521")
@QuarkusTest
class MicroProfileHealthTest {
@Test
public void testHealthUpStatus() {
- RestAssured.when().get("/health").then()
+ RestAssured.when().get("/q/health").then()
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.body("status", is("UP"),
- "checks.status", containsInAnyOrder("UP", "UP", "UP"),
+ "checks.status", containsInAnyOrder("UP", "UP"),
"checks.name",
- containsInAnyOrder("camel-readiness-checks", "camel-liveness-checks", "camel-context-check"),
- "checks.data.contextStatus", containsInAnyOrder(null, null, "Started"),
- "checks.data.'route:healthyRoute'", containsInAnyOrder(null, null, "UP"),
- "checks.data.always-up", containsInAnyOrder(null, "UP", "UP"),
- "checks.data.name", containsInAnyOrder(null, null, "quarkus-camel-example"));
+ containsInAnyOrder("camel-readiness-checks", "camel-liveness-checks"),
+ "checks.data.context", containsInAnyOrder(null, "UP"),
+ "checks.data.'route:healthyRoute'", containsInAnyOrder(null, "UP"),
+ "checks.data.always-up", containsInAnyOrder("UP", "UP"));
}
@Test
@@ -57,16 +54,14 @@ class MicroProfileHealthTest {
.then()
.statusCode(204);
- RestAssured.when().get("/health").then()
+ RestAssured.when().get("/q/health").then()
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.body("status", is("DOWN"),
- "checks.status", containsInAnyOrder("DOWN", "UP", "DOWN"),
+ "checks.status", containsInAnyOrder("DOWN", "DOWN"),
"checks.name",
- containsInAnyOrder("camel-readiness-checks", "camel-context-check", "camel-liveness-checks"),
- "checks.data.contextStatus", containsInAnyOrder(null, null, "Started"),
- "checks.data.name",
- containsInAnyOrder(null, null, "quarkus-camel-example"));
+ containsInAnyOrder("camel-readiness-checks", "camel-liveness-checks"),
+ "checks.data.context", containsInAnyOrder(null, "UP"));
} finally {
RestAssured.get("/microprofile-health/checks/failing/false")
.then()
@@ -76,7 +71,7 @@ class MicroProfileHealthTest {
@Test
public void testLivenessUpStatus() {
- RestAssured.when().get("/health/live").then()
+ RestAssured.when().get("/q/health/live").then()
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.body("status", is("UP"),
@@ -93,7 +88,7 @@ class MicroProfileHealthTest {
.then()
.statusCode(204);
- RestAssured.when().get("/health/live").then()
+ RestAssured.when().get("/q/health/live").then()
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.body("status", is("DOWN"),
@@ -111,15 +106,14 @@ class MicroProfileHealthTest {
@Test
public void testReadinessUpStatus() {
- RestAssured.when().get("/health/ready").then()
+ RestAssured.when().get("/q/health/ready").then()
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.body("status", is("UP"),
- "checks.status", containsInAnyOrder("UP", "UP"),
- "checks.name", containsInAnyOrder("camel-readiness-checks", "camel-context-check"),
- "checks.data.contextStatus", containsInAnyOrder(null, "Started"),
- "checks.data.name", containsInAnyOrder(null, "quarkus-camel-example"),
- "checks.data.test-readiness", containsInAnyOrder(null, "UP"));
+ "checks.status", containsInAnyOrder("UP"),
+ "checks.name", containsInAnyOrder("camel-readiness-checks"),
+ "checks.data.context", containsInAnyOrder("UP"),
+ "checks.data.test-readiness", containsInAnyOrder("UP"));
}
@Test
@@ -129,15 +123,14 @@ class MicroProfileHealthTest {
.then()
.statusCode(204);
- RestAssured.when().get("/health/ready").then()
+ RestAssured.when().get("/q/health/ready").then()
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.body("status", is("DOWN"),
- "checks.status", containsInAnyOrder("UP", "DOWN"),
- "checks.name", containsInAnyOrder("camel-readiness-checks", "camel-context-check"),
- "checks.data.contextStatus", containsInAnyOrder(null, "Started"),
- "checks.data.name", containsInAnyOrder(null, "quarkus-camel-example"),
- "checks.data.test-readiness", containsInAnyOrder(null, "UP"));
+ "checks.status", containsInAnyOrder("DOWN"),
+ "checks.name", containsInAnyOrder("camel-readiness-checks"),
+ "checks.data.context", containsInAnyOrder("UP"),
+ "checks.data.test-readiness", containsInAnyOrder("UP"));
} finally {
RestAssured.get("/microprofile-health/checks/failing/false")
.then()
@@ -152,11 +145,11 @@ class MicroProfileHealthTest {
.then()
.statusCode(204);
- RestAssured.when().get("/health").then()
+ RestAssured.when().get("/q/health").then()
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.body("status", is("DOWN"),
- "checks.data.'route:healthyRoute'", containsInAnyOrder(null, null, "DOWN"));
+ "checks.data.'route:healthyRoute'", containsInAnyOrder(null, "DOWN"));
} finally {
RestAssured.get("/microprofile-health/route/healthyRoute/start")
.then()
@@ -172,15 +165,15 @@ class MicroProfileHealthTest {
.statusCode(204);
// Configured failure threshold and interval should allow the initial health state be UP
- RestAssured.when().get("/health").then()
+ RestAssured.when().get("/q/health").then()
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.body("status", is("UP"),
- "checks.data.'route:checkIntervalThreshold'", containsInAnyOrder(null, null, "UP"));
+ "checks.data.'route:checkIntervalThreshold'", containsInAnyOrder(null, "UP"));
// Poll the health endpoint until the threshold / interval is exceeded and the health state transitions to DOWN
Awaitility.await().atMost(10, TimeUnit.SECONDS).pollDelay(50, TimeUnit.MILLISECONDS).until(() -> {
- JsonPath result = RestAssured.when().get("/health").then()
+ JsonPath result = RestAssured.when().get("/q/health").then()
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.extract()
@@ -197,7 +190,7 @@ class MicroProfileHealthTest {
// Wait for the threshold check to report status UP
Awaitility.await().atMost(10, TimeUnit.SECONDS).pollDelay(50, TimeUnit.MILLISECONDS).until(() -> {
- JsonPath result = RestAssured.when().get("/health").then()
+ JsonPath result = RestAssured.when().get("/q/health").then()
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.extract()
diff --git a/integration-tests/microprofile/src/test/java/org/apache/camel/quarkus/component/microprofile/it/health/MicroprofileHealthIT.java b/integration-tests/microprofile/src/test/java/org/apache/camel/quarkus/component/microprofile/it/health/MicroprofileHealthIT.java
index 9a21dde..9d3e33b 100644
--- a/integration-tests/microprofile/src/test/java/org/apache/camel/quarkus/component/microprofile/it/health/MicroprofileHealthIT.java
+++ b/integration-tests/microprofile/src/test/java/org/apache/camel/quarkus/component/microprofile/it/health/MicroprofileHealthIT.java
@@ -17,9 +17,7 @@
package org.apache.camel.quarkus.component.microprofile.it.health;
import io.quarkus.test.junit.NativeImageTest;
-import org.junit.jupiter.api.Disabled;
-@Disabled("https://github.com/apache/camel-quarkus/issues/2521")
@NativeImageTest
class MicroprofileHealthIT extends MicroProfileHealthTest {