You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2023/08/10 03:28:43 UTC
[camel-quarkus] 02/10: Fix CamelKafkaHealthCheckTest
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 89c45e3f98f40916c06c5a1e56b872f3cac0bd90
Author: James Netherton <ja...@gmail.com>
AuthorDate: Tue Aug 1 07:36:19 2023 +0100
Fix CamelKafkaHealthCheckTest
---
.../camel/quarkus/component/kafka/it/CamelKafkaHealthCheckTest.java | 6 +++---
.../camel/quarkus/component/kafka/it/KafkaHealthCheckProfile.java | 4 +++-
2 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaHealthCheckTest.java b/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaHealthCheckTest.java
index 8ac3abb560..31d4111ba4 100644
--- a/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaHealthCheckTest.java
+++ b/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/CamelKafkaHealthCheckTest.java
@@ -52,8 +52,8 @@ public class CamelKafkaHealthCheckTest {
.contentType(ContentType.JSON)
.header("Content-Type", containsString("charset=UTF-8"))
.body("status", is("DOWN"),
- "checks.find { it.name == 'camel-components' }.status", is("DOWN"),
- "checks.find { it.name == 'camel-components' }.data.topic", notNullValue(),
- "checks.find { it.name == 'camel-components' }.data.'client.id'", notNullValue());
+ "checks.find { it.name == 'camel-producers' }.status", is("DOWN"),
+ "checks.find { it.name == 'camel-producers' }.data.topic", notNullValue(),
+ "checks.find { it.name == 'camel-producers' }.data.'client.id'", notNullValue());
}
}
diff --git a/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/KafkaHealthCheckProfile.java b/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/KafkaHealthCheckProfile.java
index 620c5dcd3f..5a80ef842c 100644
--- a/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/KafkaHealthCheckProfile.java
+++ b/integration-tests/kafka/src/test/java/org/apache/camel/quarkus/component/kafka/it/KafkaHealthCheckProfile.java
@@ -24,6 +24,8 @@ public class KafkaHealthCheckProfile implements QuarkusTestProfile {
@Override
public Map<String, String> getConfigOverrides() {
// force shutdown
- return Map.of("camel.main.shutdownTimeout", "10");
+ return Map.of(
+ "camel.main.shutdownTimeout", "10",
+ "camel.health.producers-enabled", "true");
}
}