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());

Reply via email to