This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push: new 747a4ce094f CAMEL-22083: CQL (#18128) 747a4ce094f is described below commit 747a4ce094febc3db8849f82adb78aa62b42e2cd Author: Federico Mariani <34543311+cro...@users.noreply.github.com> AuthorDate: Tue May 20 14:07:42 2025 +0200 CAMEL-22083: CQL (#18128) --- .../test/infra/cassandra/services/CassandraInfraService.java | 4 ++++ .../services/CassandraLocalContainerInfraService.java | 12 +++++++++++- 2 files changed, 15 insertions(+), 1 deletion(-) diff --git a/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/CassandraInfraService.java b/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/CassandraInfraService.java index e8a611f44d0..e9c8efc3e7d 100644 --- a/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/CassandraInfraService.java +++ b/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/CassandraInfraService.java @@ -31,4 +31,8 @@ public interface CassandraInfraService extends InfrastructureService { } String getCassandraHost(); + + String hosts(); + + int port(); } diff --git a/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/CassandraLocalContainerInfraService.java b/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/CassandraLocalContainerInfraService.java index eaa87960ec8..3ea58423dc7 100644 --- a/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/CassandraLocalContainerInfraService.java +++ b/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/CassandraLocalContainerInfraService.java @@ -56,14 +56,24 @@ public class CassandraLocalContainerInfraService implements CassandraInfraServic @Override public int getCQL3Port() { - return container.getMappedPort(CassandraContainer.CQL_PORT); + return port(); } @Override public String getCassandraHost() { + return hosts(); + } + + @Override + public String hosts() { return container.getHost(); } + @Override + public int port() { + return container.getMappedPort(CassandraContainer.CQL_PORT); + } + @Override public void registerProperties() { System.setProperty(CassandraProperties.CASSANDRA_HOST, getCassandraHost());