diff --git a/app/src/main/java/io/apicurio/registry/metrics/health/liveness/PersistenceExceptionLivenessCheck.java b/app/src/main/java/io/apicurio/registry/metrics/health/liveness/PersistenceExceptionLivenessCheck.java index f82f67ddec..c7188cd03b 100644 --- a/app/src/main/java/io/apicurio/registry/metrics/health/liveness/PersistenceExceptionLivenessCheck.java +++ b/app/src/main/java/io/apicurio/registry/metrics/health/liveness/PersistenceExceptionLivenessCheck.java @@ -1,12 +1,11 @@ package io.apicurio.registry.metrics.health.liveness; -import jakarta.enterprise.context.ApplicationScoped; -import jakarta.enterprise.inject.Default; -import jakarta.inject.Inject; - import io.apicurio.common.apps.config.Info; import io.apicurio.registry.metrics.health.AbstractErrorCounterHealthCheck; import jakarta.annotation.PostConstruct; +import jakarta.enterprise.context.ApplicationScoped; +import jakarta.enterprise.inject.Default; +import jakarta.inject.Inject; import org.eclipse.microprofile.config.inject.ConfigProperty; import org.eclipse.microprofile.health.HealthCheck; import org.eclipse.microprofile.health.HealthCheckResponse; @@ -67,7 +66,7 @@ public synchronized HealthCheckResponse call() { return HealthCheckResponse.builder() .name("PersistenceExceptionLivenessCheck") .withData("errorCount", errorCounter) - .up() + .status(up) .build(); } diff --git a/app/src/main/java/io/apicurio/registry/metrics/health/liveness/ResponseErrorLivenessCheck.java b/app/src/main/java/io/apicurio/registry/metrics/health/liveness/ResponseErrorLivenessCheck.java index 63da75b599..26e31b9792 100644 --- a/app/src/main/java/io/apicurio/registry/metrics/health/liveness/ResponseErrorLivenessCheck.java +++ b/app/src/main/java/io/apicurio/registry/metrics/health/liveness/ResponseErrorLivenessCheck.java @@ -1,12 +1,11 @@ package io.apicurio.registry.metrics.health.liveness; -import jakarta.enterprise.context.ApplicationScoped; -import jakarta.enterprise.inject.Default; -import jakarta.inject.Inject; - import io.apicurio.common.apps.config.Info; import io.apicurio.registry.metrics.health.AbstractErrorCounterHealthCheck; import jakarta.annotation.PostConstruct; +import jakarta.enterprise.context.ApplicationScoped; +import jakarta.enterprise.inject.Default; +import jakarta.inject.Inject; import org.eclipse.microprofile.config.inject.ConfigProperty; import org.eclipse.microprofile.health.HealthCheck; import org.eclipse.microprofile.health.HealthCheckResponse; @@ -65,7 +64,7 @@ public synchronized HealthCheckResponse call() { return HealthCheckResponse.builder() .name("ResponseErrorLivenessCheck") .withData("errorCount", errorCounter) - .up() + .status(up) .build(); } diff --git a/app/src/main/java/io/apicurio/registry/metrics/health/readiness/PersistenceTimeoutReadinessCheck.java b/app/src/main/java/io/apicurio/registry/metrics/health/readiness/PersistenceTimeoutReadinessCheck.java index e70a1921e0..776e714c7d 100644 --- a/app/src/main/java/io/apicurio/registry/metrics/health/readiness/PersistenceTimeoutReadinessCheck.java +++ b/app/src/main/java/io/apicurio/registry/metrics/health/readiness/PersistenceTimeoutReadinessCheck.java @@ -1,20 +1,19 @@ package io.apicurio.registry.metrics.health.readiness; -import java.time.Duration; - -import jakarta.enterprise.context.ApplicationScoped; -import jakarta.enterprise.inject.Default; -import jakarta.inject.Inject; - import io.apicurio.common.apps.config.Info; import io.apicurio.registry.metrics.health.AbstractErrorCounterHealthCheck; import jakarta.annotation.PostConstruct; +import jakarta.enterprise.context.ApplicationScoped; +import jakarta.enterprise.inject.Default; +import jakarta.inject.Inject; import org.eclipse.microprofile.config.inject.ConfigProperty; import org.eclipse.microprofile.health.HealthCheck; import org.eclipse.microprofile.health.HealthCheckResponse; import org.eclipse.microprofile.health.Liveness; import org.slf4j.Logger; +import java.time.Duration; + /** * Fail readiness check if the duration of processing a artifactStore operation is too high. * @@ -74,7 +73,7 @@ public synchronized HealthCheckResponse call() { return HealthCheckResponse.builder() .name("PersistenceTimeoutReadinessCheck") .withData("errorCount", errorCounter) - .up() + .status(up) .build(); } diff --git a/app/src/main/java/io/apicurio/registry/metrics/health/readiness/ResponseTimeoutReadinessCheck.java b/app/src/main/java/io/apicurio/registry/metrics/health/readiness/ResponseTimeoutReadinessCheck.java index d921080ce5..b396e473db 100644 --- a/app/src/main/java/io/apicurio/registry/metrics/health/readiness/ResponseTimeoutReadinessCheck.java +++ b/app/src/main/java/io/apicurio/registry/metrics/health/readiness/ResponseTimeoutReadinessCheck.java @@ -3,14 +3,6 @@ import io.apicurio.common.apps.config.Info; import io.apicurio.registry.metrics.health.AbstractErrorCounterHealthCheck; import jakarta.annotation.PostConstruct; -import org.eclipse.microprofile.config.inject.ConfigProperty; -import org.eclipse.microprofile.health.HealthCheck; -import org.eclipse.microprofile.health.HealthCheckResponse; -import org.eclipse.microprofile.health.Readiness; -import org.slf4j.Logger; -import java.time.Duration; -import java.time.Instant; -import java.time.format.DateTimeParseException; import jakarta.enterprise.context.ApplicationScoped; import jakarta.enterprise.inject.Default; import jakarta.enterprise.inject.Instance; @@ -20,6 +12,15 @@ import jakarta.ws.rs.container.ContainerResponseContext; import jakarta.ws.rs.container.ContainerResponseFilter; import jakarta.ws.rs.ext.Provider; +import org.eclipse.microprofile.config.inject.ConfigProperty; +import org.eclipse.microprofile.health.HealthCheck; +import org.eclipse.microprofile.health.HealthCheckResponse; +import org.eclipse.microprofile.health.Readiness; +import org.slf4j.Logger; + +import java.time.Duration; +import java.time.Instant; +import java.time.format.DateTimeParseException; /** * @author Jakub Senko m@jsenko.net @@ -94,7 +95,7 @@ public void filter(ContainerRequestContext requestContext, ContainerResponseCont log.error("Value '{}' of header '{}' is the wrong format!", requestStart, HEADER_NAME); } - } else if (responseContext.getStatus() != 404){ + } else if (responseContext.getStatus() != 404) { log.warn("Expected header '{}' not found.", HEADER_NAME); } } @@ -105,7 +106,7 @@ public synchronized HealthCheckResponse call() { return HealthCheckResponse.builder() .name("ResponseTimeoutReadinessCheck") .withData("errorCount", errorCounter) - .up() + .status(up) .build(); } }