You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kie.apache.org by eg...@apache.org on 2025/09/10 09:14:42 UTC
(incubator-kie-kogito-apps) branch main updated: [incubator-kie-issues-2080] Kogito data-index and job-service readiness probes are not working as expected. (#2265)
This is an automated email from the ASF dual-hosted git repository.
egonzalez pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-kie-kogito-apps.git
The following commit(s) were added to refs/heads/main by this push:
new 2e309120c [incubator-kie-issues-2080] Kogito data-index and job-service readiness probes are not working as expected. (#2265)
2e309120c is described below
commit 2e309120cb54c634b7c5f02658acfb42732e2e18
Author: Enrique <en...@ibm.com>
AuthorDate: Wed Sep 10 11:14:38 2025 +0200
[incubator-kie-issues-2080] Kogito data-index and job-service readiness probes are not working as expected. (#2265)
* [incubator-kie-issues-2080] Kogito data-index and job-service readiness probes are not working as expected.
* Update QuarkusDataIndexLivenessHealthCheck.java
* Update QuarkusDataIndexReadinessHealthCheck.java
---
.../kogito/app/audit/api/SubsystemConstants.java | 1 +
.../QuarkusDataAuditLivenessHealthCheck.java} | 27 ++++---
.../QuarkusDataAuditReadinessHealthCheck.java} | 27 ++++---
.../kogito-addons-data-audit-springboot/pom.xml | 20 +++--
.../springboot/DataAuditHealthIndicator.java} | 21 +++---
.../runtime/pom.xml | 4 +
.../QuarkusDataIndexLivenessHealthCheck.java | 26 ++++---
.../QuarkusDataIndexReadinessHealthCheck.java | 26 ++++---
.../data-index-common-addons-springboot/pom.xml | 86 +++++++++++++---------
.../sprinboot/addon/DataIndexHealthIndicator.java | 21 +++---
.../QuarkusEmbeddedJobsLivenessHealthCheck.java | 26 ++++---
.../QuarkusEmbeddedJobsReadinessHealthCheck.java | 26 ++++---
.../kogito-addons-springboot-embedded-jobs/pom.xml | 3 +-
.../springboot/EmbeddedJobsHealthIndicator.java | 21 +++---
14 files changed, 194 insertions(+), 141 deletions(-)
diff --git a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java b/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
index a4267d9d1..8d4d2524a 100644
--- a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
+++ b/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
@@ -24,6 +24,7 @@ public final class SubsystemConstants {
// do nothing
}
+ public static final String DATA_AUDIT_NAME = "Data Audit";
public static final String DATA_AUDIT_PATH = "/data-audit";
public static final String DATA_AUDIT_QUERY_PATH = DATA_AUDIT_PATH + "/q";
public static final String DATA_AUDIT_REGISTRY_PATH = DATA_AUDIT_PATH + "/r";
diff --git a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java b/data-audit/kogito-addons-data-audit-quarkus/src/main/java/org/kie/kogito/app/audit/quarkus/QuarkusDataAuditLivenessHealthCheck.java
similarity index 54%
copy from data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
copy to data-audit/kogito-addons-data-audit-quarkus/src/main/java/org/kie/kogito/app/audit/quarkus/QuarkusDataAuditLivenessHealthCheck.java
index a4267d9d1..87bf32a94 100644
--- a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
+++ b/data-audit/kogito-addons-data-audit-quarkus/src/main/java/org/kie/kogito/app/audit/quarkus/QuarkusDataAuditLivenessHealthCheck.java
@@ -16,19 +16,24 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.kie.kogito.app.audit.api;
+package org.kie.kogito.app.audit.quarkus;
-public final class SubsystemConstants {
+import org.eclipse.microprofile.health.HealthCheck;
+import org.eclipse.microprofile.health.HealthCheckResponse;
+import org.eclipse.microprofile.health.HealthCheckResponseBuilder;
+import org.eclipse.microprofile.health.Readiness;
+import org.kie.kogito.app.audit.api.SubsystemConstants;
- private SubsystemConstants() {
- // do nothing
- }
+import jakarta.enterprise.context.ApplicationScoped;
+
+@Readiness
+@ApplicationScoped
+public class QuarkusDataAuditLivenessHealthCheck implements HealthCheck {
- public static final String DATA_AUDIT_PATH = "/data-audit";
- public static final String DATA_AUDIT_QUERY_PATH = DATA_AUDIT_PATH + "/q";
- public static final String DATA_AUDIT_REGISTRY_PATH = DATA_AUDIT_PATH + "/r";
+ @Override
+ public HealthCheckResponse call() {
+ HealthCheckResponseBuilder reponse = HealthCheckResponse.builder().name(SubsystemConstants.DATA_AUDIT_NAME).up();
+ return reponse.build();
+ }
- public static final String KOGITO_PROCESSINSTANCES_EVENTS = "kogito-processinstances-events";
- public static final String KOGITO_USERTASKINSTANCES_EVENTS = "kogito-usertaskinstances-events";
- public static final String KOGITO_JOBS_EVENTS = "kogito-jobs-events";
}
diff --git a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java b/data-audit/kogito-addons-data-audit-quarkus/src/main/java/org/kie/kogito/app/audit/quarkus/QuarkusDataAuditReadinessHealthCheck.java
similarity index 54%
copy from data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
copy to data-audit/kogito-addons-data-audit-quarkus/src/main/java/org/kie/kogito/app/audit/quarkus/QuarkusDataAuditReadinessHealthCheck.java
index a4267d9d1..b03500827 100644
--- a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
+++ b/data-audit/kogito-addons-data-audit-quarkus/src/main/java/org/kie/kogito/app/audit/quarkus/QuarkusDataAuditReadinessHealthCheck.java
@@ -16,19 +16,24 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.kie.kogito.app.audit.api;
+package org.kie.kogito.app.audit.quarkus;
-public final class SubsystemConstants {
+import org.eclipse.microprofile.health.HealthCheck;
+import org.eclipse.microprofile.health.HealthCheckResponse;
+import org.eclipse.microprofile.health.HealthCheckResponseBuilder;
+import org.eclipse.microprofile.health.Liveness;
+import org.kie.kogito.app.audit.api.SubsystemConstants;
- private SubsystemConstants() {
- // do nothing
- }
+import jakarta.enterprise.context.ApplicationScoped;
+
+@Liveness
+@ApplicationScoped
+public class QuarkusDataAuditReadinessHealthCheck implements HealthCheck {
- public static final String DATA_AUDIT_PATH = "/data-audit";
- public static final String DATA_AUDIT_QUERY_PATH = DATA_AUDIT_PATH + "/q";
- public static final String DATA_AUDIT_REGISTRY_PATH = DATA_AUDIT_PATH + "/r";
+ @Override
+ public HealthCheckResponse call() {
+ HealthCheckResponseBuilder reponse = HealthCheckResponse.builder().name(SubsystemConstants.DATA_AUDIT_NAME).up();
+ return reponse.build();
+ }
- public static final String KOGITO_PROCESSINSTANCES_EVENTS = "kogito-processinstances-events";
- public static final String KOGITO_USERTASKINSTANCES_EVENTS = "kogito-usertaskinstances-events";
- public static final String KOGITO_JOBS_EVENTS = "kogito-jobs-events";
}
diff --git a/data-audit/kogito-addons-data-audit-springboot/pom.xml b/data-audit/kogito-addons-data-audit-springboot/pom.xml
index c68c2c159..5beaeab35 100644
--- a/data-audit/kogito-addons-data-audit-springboot/pom.xml
+++ b/data-audit/kogito-addons-data-audit-springboot/pom.xml
@@ -60,14 +60,15 @@
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
- <version>${version.org.springframework.boot}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
- <version>${version.org.springframework.boot}</version>
</dependency>
-
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-actuator</artifactId>
+ </dependency>
<!--testing -->
<dependency>
<groupId>org.kie.kogito</groupId>
@@ -77,7 +78,6 @@
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
- <version>${version.org.springframework.boot}</version>
<scope>test</scope>
</dependency>
<dependency>
@@ -87,7 +87,17 @@
</dependency>
</dependencies>
-
+ <dependencyManagement>
+ <dependencies>
+ <dependency>
+ <groupId>org.kie.kogito</groupId>
+ <artifactId>kogito-spring-boot-bom</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>import</scope>
+ </dependency>
+ </dependencies>
+ </dependencyManagement>
<profiles>
<profile>
<id>jpa-h2</id>
diff --git a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java b/data-audit/kogito-addons-data-audit-springboot/src/main/java/org/kie/kogito/app/audit/springboot/DataAuditHealthIndicator.java
similarity index 56%
copy from data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
copy to data-audit/kogito-addons-data-audit-springboot/src/main/java/org/kie/kogito/app/audit/springboot/DataAuditHealthIndicator.java
index a4267d9d1..814b11ce0 100644
--- a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
+++ b/data-audit/kogito-addons-data-audit-springboot/src/main/java/org/kie/kogito/app/audit/springboot/DataAuditHealthIndicator.java
@@ -16,19 +16,18 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.kie.kogito.app.audit.api;
+package org.kie.kogito.app.audit.springboot;
-public final class SubsystemConstants {
+import org.springframework.boot.actuate.health.Health;
+import org.springframework.boot.actuate.health.HealthIndicator;
+import org.springframework.stereotype.Component;
- private SubsystemConstants() {
- // do nothing
- }
+@Component
+public class DataAuditHealthIndicator implements HealthIndicator {
- public static final String DATA_AUDIT_PATH = "/data-audit";
- public static final String DATA_AUDIT_QUERY_PATH = DATA_AUDIT_PATH + "/q";
- public static final String DATA_AUDIT_REGISTRY_PATH = DATA_AUDIT_PATH + "/r";
+ @Override
+ public Health health() {
+ return Health.up().build();
+ }
- public static final String KOGITO_PROCESSINSTANCES_EVENTS = "kogito-processinstances-events";
- public static final String KOGITO_USERTASKINSTANCES_EVENTS = "kogito-usertaskinstances-events";
- public static final String KOGITO_JOBS_EVENTS = "kogito-jobs-events";
}
diff --git a/data-index/data-index-quarkus/kogito-addons-quarkus-data-index/kogito-addons-quarkus-data-index-common/runtime/pom.xml b/data-index/data-index-quarkus/kogito-addons-quarkus-data-index/kogito-addons-quarkus-data-index-common/runtime/pom.xml
index 471aac331..9cac9ddec 100644
--- a/data-index/data-index-quarkus/kogito-addons-quarkus-data-index/kogito-addons-quarkus-data-index-common/runtime/pom.xml
+++ b/data-index/data-index-quarkus/kogito-addons-quarkus-data-index/kogito-addons-quarkus-data-index-common/runtime/pom.xml
@@ -47,6 +47,10 @@
<groupId>org.kie.kogito</groupId>
<artifactId>data-index-graphql-addons</artifactId>
</dependency>
+ <dependency>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-smallrye-health</artifactId>
+ </dependency>
</dependencies>
<build>
<plugins>
diff --git a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java b/data-index/data-index-quarkus/kogito-addons-quarkus-data-index/kogito-addons-quarkus-data-index-common/runtime/src/main/java/org/kie/kogito/index/addon/health/QuarkusDataIndexLivenessHealthCheck.java
similarity index 56%
copy from data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
copy to data-index/data-index-quarkus/kogito-addons-quarkus-data-index/kogito-addons-quarkus-data-index-common/runtime/src/main/java/org/kie/kogito/index/addon/health/QuarkusDataIndexLivenessHealthCheck.java
index a4267d9d1..13e6711a2 100644
--- a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
+++ b/data-index/data-index-quarkus/kogito-addons-quarkus-data-index/kogito-addons-quarkus-data-index-common/runtime/src/main/java/org/kie/kogito/index/addon/health/QuarkusDataIndexLivenessHealthCheck.java
@@ -16,19 +16,23 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.kie.kogito.app.audit.api;
+package org.kie.kogito.index.addon.health;
-public final class SubsystemConstants {
+import org.eclipse.microprofile.health.HealthCheck;
+import org.eclipse.microprofile.health.HealthCheckResponse;
+import org.eclipse.microprofile.health.HealthCheckResponseBuilder;
+import org.eclipse.microprofile.health.Readiness;
- private SubsystemConstants() {
- // do nothing
- }
+import jakarta.enterprise.context.ApplicationScoped;
+
+@Readiness
+@ApplicationScoped
+public class QuarkusDataIndexLivenessHealthCheck implements HealthCheck {
- public static final String DATA_AUDIT_PATH = "/data-audit";
- public static final String DATA_AUDIT_QUERY_PATH = DATA_AUDIT_PATH + "/q";
- public static final String DATA_AUDIT_REGISTRY_PATH = DATA_AUDIT_PATH + "/r";
+ @Override
+ public HealthCheckResponse call() {
+ HealthCheckResponseBuilder reponse = HealthCheckResponse.builder().name("Data Index").up();
+ return reponse.build();
+ }
- public static final String KOGITO_PROCESSINSTANCES_EVENTS = "kogito-processinstances-events";
- public static final String KOGITO_USERTASKINSTANCES_EVENTS = "kogito-usertaskinstances-events";
- public static final String KOGITO_JOBS_EVENTS = "kogito-jobs-events";
}
diff --git a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java b/data-index/data-index-quarkus/kogito-addons-quarkus-data-index/kogito-addons-quarkus-data-index-common/runtime/src/main/java/org/kie/kogito/index/addon/health/QuarkusDataIndexReadinessHealthCheck.java
similarity index 56%
copy from data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
copy to data-index/data-index-quarkus/kogito-addons-quarkus-data-index/kogito-addons-quarkus-data-index-common/runtime/src/main/java/org/kie/kogito/index/addon/health/QuarkusDataIndexReadinessHealthCheck.java
index a4267d9d1..02a90da0e 100644
--- a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
+++ b/data-index/data-index-quarkus/kogito-addons-quarkus-data-index/kogito-addons-quarkus-data-index-common/runtime/src/main/java/org/kie/kogito/index/addon/health/QuarkusDataIndexReadinessHealthCheck.java
@@ -16,19 +16,23 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.kie.kogito.app.audit.api;
+package org.kie.kogito.index.addon.health;
-public final class SubsystemConstants {
+import org.eclipse.microprofile.health.HealthCheck;
+import org.eclipse.microprofile.health.HealthCheckResponse;
+import org.eclipse.microprofile.health.HealthCheckResponseBuilder;
+import org.eclipse.microprofile.health.Liveness;
- private SubsystemConstants() {
- // do nothing
- }
+import jakarta.enterprise.context.ApplicationScoped;
+
+@Liveness
+@ApplicationScoped
+public class QuarkusDataIndexReadinessHealthCheck implements HealthCheck {
- public static final String DATA_AUDIT_PATH = "/data-audit";
- public static final String DATA_AUDIT_QUERY_PATH = DATA_AUDIT_PATH + "/q";
- public static final String DATA_AUDIT_REGISTRY_PATH = DATA_AUDIT_PATH + "/r";
+ @Override
+ public HealthCheckResponse call() {
+ HealthCheckResponseBuilder reponse = HealthCheckResponse.builder().name("Data Index").up();
+ return reponse.build();
+ }
- public static final String KOGITO_PROCESSINSTANCES_EVENTS = "kogito-processinstances-events";
- public static final String KOGITO_USERTASKINSTANCES_EVENTS = "kogito-usertaskinstances-events";
- public static final String KOGITO_JOBS_EVENTS = "kogito-jobs-events";
}
diff --git a/data-index/data-index-springboot/data-index-common-addons-springboot/pom.xml b/data-index/data-index-springboot/data-index-common-addons-springboot/pom.xml
index 9c97a426e..f39fc5a11 100644
--- a/data-index/data-index-springboot/data-index-common-addons-springboot/pom.xml
+++ b/data-index/data-index-springboot/data-index-common-addons-springboot/pom.xml
@@ -19,40 +19,56 @@
under the License.
-->
-<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
- <modelVersion>4.0.0</modelVersion>
- <parent>
- <groupId>org.kie.kogito</groupId>
- <artifactId>data-index-springboot</artifactId>
- <version>999-SNAPSHOT</version>
- </parent>
-
- <artifactId>data-index-common-addons-springboot</artifactId>
- <name>Kogito Apps :: Kogito Data Index SpringBoot Add-Ons Common</name>
-
- <properties>
- <java.module.name>org.kie.kogito.index.springboot.addons.common</java.module.name>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.kie.kogito</groupId>
- <artifactId>data-index-common-springboot</artifactId>
- </dependency>
- <dependency>
- <groupId>org.kie.kogito</groupId>
- <artifactId>data-index-common-addons</artifactId>
- </dependency>
- <dependency>
- <groupId>org.kie</groupId>
- <artifactId>kie-addons-process-svg</artifactId>
- </dependency>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter</artifactId>
- <version>${version.org.springframework.boot}</version>
- </dependency>
- </dependencies>
+<project
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"
+ xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.kie.kogito</groupId>
+ <artifactId>data-index-springboot</artifactId>
+ <version>999-SNAPSHOT</version>
+ </parent>
+ <artifactId>data-index-common-addons-springboot</artifactId>
+ <name>Kogito Apps :: Kogito Data Index SpringBoot Add-Ons Common</name>
+
+ <properties>
+ <java.module.name>org.kie.kogito.index.springboot.addons.common</java.module.name>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.kie.kogito</groupId>
+ <artifactId>data-index-common-springboot</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.kie.kogito</groupId>
+ <artifactId>data-index-common-addons</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.kie</groupId>
+ <artifactId>kie-addons-process-svg</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-actuator</artifactId>
+ </dependency>
+ </dependencies>
+
+ <dependencyManagement>
+ <dependencies>
+ <dependency>
+ <groupId>org.kie.kogito</groupId>
+ <artifactId>kogito-spring-boot-bom</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>import</scope>
+ </dependency>
+ </dependencies>
+ </dependencyManagement>
</project>
diff --git a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java b/data-index/data-index-springboot/data-index-common-addons-springboot/src/main/java/org/kie/kogito/index/sprinboot/addon/DataIndexHealthIndicator.java
similarity index 56%
copy from data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
copy to data-index/data-index-springboot/data-index-common-addons-springboot/src/main/java/org/kie/kogito/index/sprinboot/addon/DataIndexHealthIndicator.java
index a4267d9d1..966b130a2 100644
--- a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
+++ b/data-index/data-index-springboot/data-index-common-addons-springboot/src/main/java/org/kie/kogito/index/sprinboot/addon/DataIndexHealthIndicator.java
@@ -16,19 +16,18 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.kie.kogito.app.audit.api;
+package org.kie.kogito.index.sprinboot.addon;
-public final class SubsystemConstants {
+import org.springframework.boot.actuate.health.Health;
+import org.springframework.boot.actuate.health.HealthIndicator;
+import org.springframework.stereotype.Component;
- private SubsystemConstants() {
- // do nothing
- }
+@Component
+public class DataIndexHealthIndicator implements HealthIndicator {
- public static final String DATA_AUDIT_PATH = "/data-audit";
- public static final String DATA_AUDIT_QUERY_PATH = DATA_AUDIT_PATH + "/q";
- public static final String DATA_AUDIT_REGISTRY_PATH = DATA_AUDIT_PATH + "/r";
+ @Override
+ public Health health() {
+ return Health.up().build();
+ }
- public static final String KOGITO_PROCESSINSTANCES_EVENTS = "kogito-processinstances-events";
- public static final String KOGITO_USERTASKINSTANCES_EVENTS = "kogito-usertaskinstances-events";
- public static final String KOGITO_JOBS_EVENTS = "kogito-jobs-events";
}
diff --git a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java b/jobs/kogito-addons-quarkus-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/quarkus/QuarkusEmbeddedJobsLivenessHealthCheck.java
similarity index 56%
copy from data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
copy to jobs/kogito-addons-quarkus-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/quarkus/QuarkusEmbeddedJobsLivenessHealthCheck.java
index a4267d9d1..69422a11e 100644
--- a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
+++ b/jobs/kogito-addons-quarkus-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/quarkus/QuarkusEmbeddedJobsLivenessHealthCheck.java
@@ -16,19 +16,23 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.kie.kogito.app.audit.api;
+package org.kie.kogito.app.jobs.quarkus;
-public final class SubsystemConstants {
+import org.eclipse.microprofile.health.HealthCheck;
+import org.eclipse.microprofile.health.HealthCheckResponse;
+import org.eclipse.microprofile.health.HealthCheckResponseBuilder;
+import org.eclipse.microprofile.health.Readiness;
- private SubsystemConstants() {
- // do nothing
- }
+import jakarta.enterprise.context.ApplicationScoped;
+
+@Readiness
+@ApplicationScoped
+public class QuarkusEmbeddedJobsLivenessHealthCheck implements HealthCheck {
- public static final String DATA_AUDIT_PATH = "/data-audit";
- public static final String DATA_AUDIT_QUERY_PATH = DATA_AUDIT_PATH + "/q";
- public static final String DATA_AUDIT_REGISTRY_PATH = DATA_AUDIT_PATH + "/r";
+ @Override
+ public HealthCheckResponse call() {
+ HealthCheckResponseBuilder reponse = HealthCheckResponse.builder().name("Embedded Jobs").up();
+ return reponse.build();
+ }
- public static final String KOGITO_PROCESSINSTANCES_EVENTS = "kogito-processinstances-events";
- public static final String KOGITO_USERTASKINSTANCES_EVENTS = "kogito-usertaskinstances-events";
- public static final String KOGITO_JOBS_EVENTS = "kogito-jobs-events";
}
diff --git a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java b/jobs/kogito-addons-quarkus-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/quarkus/QuarkusEmbeddedJobsReadinessHealthCheck.java
similarity index 56%
copy from data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
copy to jobs/kogito-addons-quarkus-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/quarkus/QuarkusEmbeddedJobsReadinessHealthCheck.java
index a4267d9d1..8307a9538 100644
--- a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
+++ b/jobs/kogito-addons-quarkus-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/quarkus/QuarkusEmbeddedJobsReadinessHealthCheck.java
@@ -16,19 +16,23 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.kie.kogito.app.audit.api;
+package org.kie.kogito.app.jobs.quarkus;
-public final class SubsystemConstants {
+import org.eclipse.microprofile.health.HealthCheck;
+import org.eclipse.microprofile.health.HealthCheckResponse;
+import org.eclipse.microprofile.health.HealthCheckResponseBuilder;
+import org.eclipse.microprofile.health.Liveness;
- private SubsystemConstants() {
- // do nothing
- }
+import jakarta.enterprise.context.ApplicationScoped;
+
+@Liveness
+@ApplicationScoped
+public class QuarkusEmbeddedJobsReadinessHealthCheck implements HealthCheck {
- public static final String DATA_AUDIT_PATH = "/data-audit";
- public static final String DATA_AUDIT_QUERY_PATH = DATA_AUDIT_PATH + "/q";
- public static final String DATA_AUDIT_REGISTRY_PATH = DATA_AUDIT_PATH + "/r";
+ @Override
+ public HealthCheckResponse call() {
+ HealthCheckResponseBuilder reponse = HealthCheckResponse.builder().name("Embedded Jobs").up();
+ return reponse.build();
+ }
- public static final String KOGITO_PROCESSINSTANCES_EVENTS = "kogito-processinstances-events";
- public static final String KOGITO_USERTASKINSTANCES_EVENTS = "kogito-usertaskinstances-events";
- public static final String KOGITO_JOBS_EVENTS = "kogito-jobs-events";
}
diff --git a/jobs/kogito-addons-springboot-embedded-jobs/pom.xml b/jobs/kogito-addons-springboot-embedded-jobs/pom.xml
index bcfb4eb59..c421170e5 100644
--- a/jobs/kogito-addons-springboot-embedded-jobs/pom.xml
+++ b/jobs/kogito-addons-springboot-embedded-jobs/pom.xml
@@ -56,12 +56,10 @@
<groupId>org.kie</groupId>
<artifactId>jobs-common-embedded</artifactId>
</dependency>
-
<dependency>
<groupId>org.kie.kogito</groupId>
<artifactId>kogito-events-core</artifactId>
</dependency>
-
<!--runtime -->
<dependency>
<groupId>com.fasterxml.jackson.datatype</groupId>
@@ -112,6 +110,7 @@
</dependency>
</dependencies>
</dependencyManagement>
+
<profiles>
<profile>
<id>jpa</id>
diff --git a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java b/jobs/kogito-addons-springboot-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/springboot/EmbeddedJobsHealthIndicator.java
similarity index 56%
copy from data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
copy to jobs/kogito-addons-springboot-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/springboot/EmbeddedJobsHealthIndicator.java
index a4267d9d1..b4de18364 100644
--- a/data-audit/data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java
+++ b/jobs/kogito-addons-springboot-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/springboot/EmbeddedJobsHealthIndicator.java
@@ -16,19 +16,18 @@
* specific language governing permissions and limitations
* under the License.
*/
-package org.kie.kogito.app.audit.api;
+package org.kie.kogito.app.jobs.springboot;
-public final class SubsystemConstants {
+import org.springframework.boot.actuate.health.Health;
+import org.springframework.boot.actuate.health.HealthIndicator;
+import org.springframework.stereotype.Component;
- private SubsystemConstants() {
- // do nothing
- }
+@Component
+public class EmbeddedJobsHealthIndicator implements HealthIndicator {
- public static final String DATA_AUDIT_PATH = "/data-audit";
- public static final String DATA_AUDIT_QUERY_PATH = DATA_AUDIT_PATH + "/q";
- public static final String DATA_AUDIT_REGISTRY_PATH = DATA_AUDIT_PATH + "/r";
+ @Override
+ public Health health() {
+ return Health.up().build();
+ }
- public static final String KOGITO_PROCESSINSTANCES_EVENTS = "kogito-processinstances-events";
- public static final String KOGITO_USERTASKINSTANCES_EVENTS = "kogito-usertaskinstances-events";
- public static final String KOGITO_JOBS_EVENTS = "kogito-jobs-events";
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@kie.apache.org
For additional commands, e-mail: commits-help@kie.apache.org