Make Cassandra port configurable.

[sdc.git] / common-app-api / src / main / java / org / openecomp / sdc / be / config / Configuration.java

diff --git a/common-app-api/src/main/java/org/openecomp/sdc/be/config/Configuration.java b/common-app-api/src/main/java/org/openecomp/sdc/be/config/Configuration.java
index f7f9834..6325f00 100644 (file)
--- a/common-app-api/src/main/java/org/openecomp/sdc/be/config/Configuration.java
+++ b/common-app-api/src/main/java/org/openecomp/sdc/be/config/Configuration.java
@@ -653,8 +653,10 @@ public class Configuration extends BasicConfiguration {
     }
 
     public static class CassandrConfig {
+        private static final Integer CASSANDRA_DEFAULT_PORT = 9042;
 
         List<String> cassandraHosts;
+        Integer cassandraPort;
         String localDataCenter;
         Long reconnectTimeout;
                Integer socketReadTimeout;
@@ -667,6 +669,10 @@ public class Configuration extends BasicConfiguration {
         String truststorePath;
         String truststorePassword;
 
+        public Integer getCassandraPort() { return cassandraPort != null ? cassandraPort : Configuration.CassandrConfig.CASSANDRA_DEFAULT_PORT; }
+
+        public void setCassandraPort(Integer cassandraPort) { this.cassandraPort = cassandraPort; }
+
         public String getLocalDataCenter() {
             return localDataCenter;
         }