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 f2e5881456d CAMEL-22083: CQL f2e5881456d is described below commit f2e5881456d5837072f050816ef3732cbc5dbee5 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Tue May 20 14:12:27 2025 +0200 CAMEL-22083: CQL --- .../services/RemoteCassandraInfraService.java | 20 +++++++++++++++----- 1 file changed, 15 insertions(+), 5 deletions(-) diff --git a/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/RemoteCassandraInfraService.java b/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/RemoteCassandraInfraService.java index 6077a0ac5f8..9fb3a211d46 100644 --- a/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/RemoteCassandraInfraService.java +++ b/test-infra/camel-test-infra-cassandra/src/main/java/org/apache/camel/test/infra/cassandra/services/RemoteCassandraInfraService.java @@ -30,6 +30,21 @@ public class RemoteCassandraInfraService implements CassandraInfraService { @Override public int getCQL3Port() { + return port(); + } + + @Override + public String getCassandraHost() { + return hosts(); + } + + @Override + public String hosts() { + return System.getProperty(CassandraProperties.CASSANDRA_HOST); + } + + @Override + public int port() { String strPort = System.getProperty(CassandraProperties.CASSANDRA_CQL3_PORT); if (strPort != null) { @@ -39,11 +54,6 @@ public class RemoteCassandraInfraService implements CassandraInfraService { return DEFAULT_CQL_PORT; } - @Override - public String getCassandraHost() { - return System.getProperty(CassandraProperties.CASSANDRA_HOST); - } - @Override public void registerProperties() { // NO-OP