This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 8db3b2fac07fec1219b18c98123dc3e73663c927 Author: Lukas Lowinger <[email protected]> AuthorDate: Thu Jul 16 14:21:23 2026 +0200 Ensure connection to Splunk HEC works before executing tests --- .../camel/quarkus/test/support/splunk/SplunkTestResource.java | 9 ++++++--- .../camel/quarkus/component/splunk/hec/it/SplunkHecTest.java | 3 +-- 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/integration-tests-support/splunk/src/test/java/org/apache/camel/quarkus/test/support/splunk/SplunkTestResource.java b/integration-tests-support/splunk/src/test/java/org/apache/camel/quarkus/test/support/splunk/SplunkTestResource.java index a6a6a355e5..3f60cc14f2 100644 --- a/integration-tests-support/splunk/src/test/java/org/apache/camel/quarkus/test/support/splunk/SplunkTestResource.java +++ b/integration-tests-support/splunk/src/test/java/org/apache/camel/quarkus/test/support/splunk/SplunkTestResource.java @@ -81,9 +81,12 @@ public class SplunkTestResource implements QuarkusTestResourceLifecycleManager { .withEnv("SPLUNK_LICENSE_URI", "Free") .withEnv("SPLUNK_GENERAL_TERMS", "--accept-sgt-current-at-splunk-com") .withEnv("TZ", TimeZone.getDefault().getID()) - .waitingFor( - Wait.forLogMessage(".*Ansible playbook complete.*\\n", 1) - .withStartupTimeout(Duration.ofMinutes(10))); + .waitingFor(Wait.forHttp("/services/collector/health") + .forPort(HEC_PORT) + .forStatusCode(200) + .usingTls() + .allowInsecure() + .withStartupTimeout(Duration.ofMinutes(10))); if (certPath != null && caCertPath != null && keystorePassword != null) { //combine key + certificates into 1 pem - required for splunk diff --git a/integration-tests/splunk-hec/src/test/java/org/apache/camel/quarkus/component/splunk/hec/it/SplunkHecTest.java b/integration-tests/splunk-hec/src/test/java/org/apache/camel/quarkus/component/splunk/hec/it/SplunkHecTest.java index 475ed070a5..d72c386bc1 100644 --- a/integration-tests/splunk-hec/src/test/java/org/apache/camel/quarkus/component/splunk/hec/it/SplunkHecTest.java +++ b/integration-tests/splunk-hec/src/test/java/org/apache/camel/quarkus/component/splunk/hec/it/SplunkHecTest.java @@ -82,8 +82,7 @@ public class SplunkHecTest { .post("/splunk-hec/send/wrongSslContextParameters") .then() .statusCode(500) - .body(Matchers.either(org.hamcrest.core.StringContains.containsString("ssl exception")) - .or(org.hamcrest.core.StringContains.containsString("Connection refused"))); + .body(Matchers.containsString("ssl exception")); } @Test
