You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ji...@apache.org on 2023/08/09 07:05:23 UTC
[camel-quarkus] 02/09: Fix CamelKafkaHealthCheckTest
This is an automated email from the ASF dual-hosted git repository.
jiriondrusek pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 2c41836693e82faaa1c79ebe975dac4de7c5cecb
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");
}
}