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 <[email protected]>
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());