1 files changed, 59 insertions, 0 deletions
diff --git a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/src/main/java/org/openecomp/core/zusammen/impl/CassandraConnectionInitializer.java b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/src/main/java/org/openecomp/core/zusammen/impl/CassandraConnectionInitializer.java
new file mode 100644
index 0000000000..47cb57c5f7
--- /dev/null
+++ b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/src/main/java/org/openecomp/core/zusammen/impl/CassandraConnectionInitializer.java
@@ -0,0 +1,59 @@
+package org.openecomp.core.zusammen.impl;
+
+
+import org.apache.commons.lang3.StringUtils;
+import org.openecomp.core.nosqldb.util.CassandraUtils;
+
+import javax.servlet.ServletContextEvent;
+import javax.servlet.ServletContextListener;
+
+/**
+ * @author Avrahamg
+ * @since April 25, 2017
+ */
+
+public class CassandraConnectionInitializer implements ServletContextListener {
+  @Override
+  public void contextInitialized(ServletContextEvent servletContextEvent) {
+    setCassandraConnectionPropertiesToSystem();
+  }
+
+  public static void setCassandraConnectionPropertiesToSystem() {
+    if (!System.getProperties().containsKey("cassandra.nodes")) {
+      System.setProperty("cassandra.nodes", StringUtils.join(CassandraUtils.getAddresses(), ','));
+    }
+    if (!System.getProperties().containsKey("cassandra.authenticate")) {
+      System
+          .setProperty("cassandra.authenticate",
+              CassandraUtils.isAuthenticate() ? "true" : "false");
+    }
+    if (!System.getProperties().containsKey("cassandra.ssl")) {
+      System.setProperty("cassandra.ssl",
+          CassandraUtils.isSsl() ? "true" : "false");
+    }
+    if (!System.getProperties().containsKey("cassandra.truststore")) {
+      System.setProperty("cassandra.truststore", CassandraUtils.getTruststore());
+    }
+    if (!System.getProperties().containsKey("cassandra.truststore.password")) {
+      System.setProperty("cassandra.truststore.password", CassandraUtils.getTruststorePassword());
+    }
+    if (!System.getProperties().containsKey("cassandra.user")) {
+      System.setProperty("cassandra.user", CassandraUtils.getUser());
+    }
+    if (!System.getProperties().containsKey("cassandra.password")) {
+      System.setProperty("cassandra.password", CassandraUtils.getPassword());
+    }
+    if (!System.getProperties().containsKey("cassandra.keyspace")) {
+      System.setProperty("cassandra.keyspace", "zusammen");
+    }
+  }
+
+  //       -Dcassandra.nodes=10.147.97.145  -Dcassandra.keyspace=zusammen -Dcassandra.authenticate=true -Dcassandra.ssl=true
+  // -Dcassandra.truststore=/apps/jetty/base/be/config/.truststore -Dcassandra.truststore.password=Aa123456
+  // -Dcassandra.user=asdc_user -Dcassandra.password=Aa1234%^!
+
+  @Override
+  public void contextDestroyed(ServletContextEvent servletContextEvent) {
+
+  }
+}