This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push: new 023e6aeadb5 CAMEL-19118: camel-health - Liveness check default false 023e6aeadb5 is described below commit 023e6aeadb5f6a47a8d283a75e0f0813a1cfd1f2 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu Mar 9 09:32:46 2023 +0100 CAMEL-19118: camel-health - Liveness check default false --- .../health/CamelMicroProfileHealthCheckTest.java | 33 +++++++++------------- ...MicroProfileHealthSupervisedRoutesMainTest.java | 2 +- .../health/CamelMicroProfileHealthTestSupport.java | 10 +++++++ 3 files changed, 25 insertions(+), 20 deletions(-) diff --git a/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthCheckTest.java b/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthCheckTest.java index cc96892509e..b0c5136bef8 100644 --- a/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthCheckTest.java +++ b/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthCheckTest.java @@ -51,12 +51,16 @@ public class CamelMicroProfileHealthCheckTest extends CamelMicroProfileHealthTes assertEquals(Status.UP.name(), healthObject.getString("status")); JsonArray checks = healthObject.getJsonArray("checks"); - assertEquals(1, checks.size()); + assertEquals(2, checks.size()); assertHealthCheckOutput("context", Status.UP, checks.getJsonObject(0), checksJson -> { assertEquals("health-context", checksJson.getString("context.name")); assertEquals(ServiceStatus.Started.name(), checksJson.getString("context.status")); }); + assertHealthCheckOutput("context", Status.UP, checks.getJsonObject(1), checksJson -> { + assertEquals("health-context", checksJson.getString("context.name")); + assertEquals(ServiceStatus.Started.name(), checksJson.getString("context.status")); + }); } @Test @@ -72,12 +76,16 @@ public class CamelMicroProfileHealthCheckTest extends CamelMicroProfileHealthTes assertEquals(Status.DOWN.name(), healthObject.getString("status")); JsonArray checks = healthObject.getJsonArray("checks"); - assertEquals(1, checks.size()); + assertEquals(2, checks.size()); assertHealthCheckOutput("context", Status.DOWN, checks.getJsonObject(0), checksJson -> { assertEquals("health-context", checksJson.getString("context.name")); assertEquals(ServiceStatus.Stopped.name(), checksJson.getString("context.status")); }); + assertHealthCheckOutput("context", Status.DOWN, checks.getJsonObject(1), checksJson -> { + assertEquals("health-context", checksJson.getString("context.name")); + assertEquals(ServiceStatus.Stopped.name(), checksJson.getString("context.status")); + }); } @Test @@ -224,10 +232,9 @@ public class CamelMicroProfileHealthCheckTest extends CamelMicroProfileHealthTes JsonObject healthObject = getHealthJson(health); assertEquals(Status.UP.name(), healthObject.getString("status")); JsonArray checks = healthObject.getJsonArray("checks"); - assertEquals(2, checks.size()); + assertEquals(1, checks.size()); assertHealthCheckOutput("test-check", Status.UP, checks.getJsonObject(0)); - assertHealthCheckOutput("test-check", Status.UP, checks.getJsonObject(1)); } @Test @@ -246,12 +253,10 @@ public class CamelMicroProfileHealthCheckTest extends CamelMicroProfileHealthTes JsonObject healthObject = getHealthJson(health); assertEquals(Status.UP.name(), healthObject.getString("status")); JsonArray checks = healthObject.getJsonArray("checks"); - assertEquals(2, checks.size()); + assertEquals(1, checks.size()); assertHealthCheckOutput("test-check", Status.UP, checks.getJsonObject(0)); - assertHealthCheckOutput("test-check", Status.UP, checks.getJsonObject(1)); - for (int i = 0; i < 5; i++) { healthCheckRegistry.unregister(check); } @@ -281,17 +286,12 @@ public class CamelMicroProfileHealthCheckTest extends CamelMicroProfileHealthTes JsonObject healthObject = getHealthJson(health); assertEquals(Status.DOWN.name(), healthObject.getString("status")); JsonArray checks = healthObject.getJsonArray("checks"); - assertEquals(2, checks.size()); + assertEquals(1, checks.size()); assertHealthCheckOutput(CamelMicroProfileHealthCheck.class.getName(), Status.DOWN, checks.getJsonObject(0), jsonObject -> { assertEquals(errorMessage, jsonObject.getString("rootCause")); }); - - assertHealthCheckOutput(CamelMicroProfileHealthCheck.class.getName(), Status.DOWN, checks.getJsonObject(1), - jsonObject -> { - assertEquals(errorMessage, jsonObject.getString("rootCause")); - }); } @Test @@ -313,17 +313,12 @@ public class CamelMicroProfileHealthCheckTest extends CamelMicroProfileHealthTes JsonObject healthObject = getHealthJson(health); assertEquals(Status.DOWN.name(), healthObject.getString("status")); JsonArray checks = healthObject.getJsonArray("checks"); - assertEquals(2, checks.size()); + assertEquals(1, checks.size()); assertHealthCheckOutput("exception-check", Status.DOWN, checks.getJsonObject(0), jsonObject -> { assertEquals(errorMessage, jsonObject.getString("error.message")); assertNotNull(jsonObject.getString("error.stacktrace")); }); - - assertHealthCheckOutput("exception-check", Status.DOWN, checks.getJsonObject(1), jsonObject -> { - assertEquals(errorMessage, jsonObject.getString("error.message")); - assertNotNull(jsonObject.getString("error.stacktrace")); - }); } @Test diff --git a/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthSupervisedRoutesMainTest.java b/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthSupervisedRoutesMainTest.java index a22dda8f2f2..7fe261ff741 100644 --- a/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthSupervisedRoutesMainTest.java +++ b/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthSupervisedRoutesMainTest.java @@ -67,7 +67,7 @@ public class CamelMicroProfileHealthSupervisedRoutesMainTest { assertEquals(Status.UP.name(), healthObject.getString("status")); JsonArray checks = healthObject.getJsonArray("checks"); - assertEquals(4, checks.size()); + assertEquals(5, checks.size()); Optional<JsonObject> camelRoutesCheck = findHealthCheck("camel-routes", checks); camelRoutesCheck.ifPresentOrElse(check -> { diff --git a/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthTestSupport.java b/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthTestSupport.java index bbb8e023370..8b7ea6869da 100644 --- a/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthTestSupport.java +++ b/components/camel-microprofile/camel-microprofile-health/src/test/java/org/apache/camel/microprofile/health/CamelMicroProfileHealthTestSupport.java @@ -121,6 +121,11 @@ public class CamelMicroProfileHealthTestSupport extends CamelTestSupport { consumer.accept(builder); } + @Override + public boolean isLiveness() { + return true; + } + @Override public boolean isReadiness() { return false; @@ -137,6 +142,11 @@ public class CamelMicroProfileHealthTestSupport extends CamelTestSupport { consumer.accept(builder); } + @Override + public boolean isReadiness() { + return true; + } + @Override public boolean isLiveness() { return false;