aboutsummaryrefslogtreecommitdiffstats
path: root/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib
diff options
context:
space:
mode:
authorshalomb <shalomb@amdocs.com>2017-11-14 17:17:51 +0200
committershalomb <shalomb@amdocs.com>2017-11-15 00:08:05 +0200
commit6319dfebab190e2ba0cb5a0e85032cd44835e947 (patch)
tree10a84c0c7750074654dfc8650336207a834bec43 /openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib
parentb6e88fe3fb33b4f21b49a4676c4b96e4dad4ffc8 (diff)
Casandra data center and consistency level
remove enrichment test Change-Id: Id2a0eda0a78ae7711ec010248edaa6a1273c5a43 Issue-Id:SDC-656 Signed-off-by: shalomb <shalomb@amdocs.com>
Diffstat (limited to 'openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib')
-rw-r--r--openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/pom.xml8
-rw-r--r--openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/src/main/java/org/openecomp/core/zusammen/impl/CassandraConnectionInitializer.java77
2 files changed, 62 insertions, 23 deletions
diff --git a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/pom.xml b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/pom.xml
index b172ec97ab..a792abbfbb 100644
--- a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/pom.xml
+++ b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/pom.xml
@@ -21,17 +21,17 @@
<dependency>
<groupId>com.amdocs.zusammen</groupId>
<artifactId>zusammen-commons-utils</artifactId>
- <version>${zusammen.version}</version>
+ <version>${zusammen.version}</version>
</dependency>
<dependency>
<groupId>com.amdocs.zusammen</groupId>
<artifactId>zusammen-adaptor-inbound-api</artifactId>
- <version>${zusammen.version}</version>
+ <version>${zusammen.version}</version>
</dependency>
<dependency>
<groupId>com.amdocs.zusammen</groupId>
<artifactId>zusammen-adaptor-inbound-impl</artifactId>
- <version>${zusammen.version}</version>
+ <version>${zusammen.version}</version>
<scope>runtime</scope>
</dependency>
<dependency>
@@ -53,7 +53,7 @@
<dependency>
<groupId>com.amdocs.zusammen.plugin</groupId>
<artifactId>zusammen-search-index-empty-plugin</artifactId>
- <version>${zusammen.version}</version>
+ <version>${zusammen-index-store.version}</version>
<scope>runtime</scope>
</dependency>
<dependency>
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
index 47cb57c5f7..0115ab6d5b 100644
--- 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
@@ -6,6 +6,7 @@ import org.openecomp.core.nosqldb.util.CassandraUtils;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
+import java.util.Objects;
/**
* @author Avrahamg
@@ -13,39 +14,77 @@ import javax.servlet.ServletContextListener;
*/
public class CassandraConnectionInitializer implements ServletContextListener {
+
+ private static String DATA_CENTER_PROPERTY_NAME = "cassandra.datacenter";
+ private static String CONSISTENCY_LEVEL_PROPERTY_NAME = "cassandra.consistency.level";
+ private static String NODES_PROPERTY_NAME = "cassandra.nodes";
+ private static String AUTHENTICATE_PROPERTY_NAME = "cassandra.authenticate";
+ private static String TRUE = "true";
+ private static String FALSE = "false";
+ private static String SSL_PROPERTY_NAME = "cassandra.ssl";
+ private static String TRUSTSTORE_PROPERTY_NAME = "cassandra.truststore";
+ private static String TRUSTSTORE_PASSWORD_PROPERTY_NAME = "cassandra.truststore.password";
+ private static String USER_PROPERTY_NAME = "cassandra.user";
+ private static String PASSWORD_PROPERTY_NAME = "cassandra.password";
+ private static String KEYSPACE_PROPERTY_NAME = "cassandra.keyspace";
+ private static String ZUSAMMEN = "zusammen";
+
@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(NODES_PROPERTY_NAME)) {
+ System.setProperty(NODES_PROPERTY_NAME, StringUtils.join(CassandraUtils.getAddresses(), ','));
+ }
+
+ if (!System.getProperties().containsKey(AUTHENTICATE_PROPERTY_NAME)) {
+ System.setProperty(AUTHENTICATE_PROPERTY_NAME,
+ CassandraUtils.isAuthenticate() ? TRUE : FALSE);
+ }
+ if (!System.getProperties().containsKey(SSL_PROPERTY_NAME)) {
+ System.setProperty(SSL_PROPERTY_NAME,
+ CassandraUtils.isSsl() ? TRUE : FALSE);
}
- if (!System.getProperties().containsKey("cassandra.authenticate")) {
- System
- .setProperty("cassandra.authenticate",
- CassandraUtils.isAuthenticate() ? "true" : "false");
+
+ if (!System.getProperties().containsKey(TRUSTSTORE_PROPERTY_NAME)) {
+ System.setProperty(TRUSTSTORE_PROPERTY_NAME, CassandraUtils.getTruststore());
}
- if (!System.getProperties().containsKey("cassandra.ssl")) {
- System.setProperty("cassandra.ssl",
- CassandraUtils.isSsl() ? "true" : "false");
+
+ if (!System.getProperties().containsKey(TRUSTSTORE_PASSWORD_PROPERTY_NAME)) {
+ System.setProperty(TRUSTSTORE_PASSWORD_PROPERTY_NAME, CassandraUtils.getTruststorePassword());
}
- if (!System.getProperties().containsKey("cassandra.truststore")) {
- System.setProperty("cassandra.truststore", CassandraUtils.getTruststore());
+
+ if (!System.getProperties().containsKey(USER_PROPERTY_NAME)) {
+ System.setProperty(USER_PROPERTY_NAME, CassandraUtils.getUser());
}
- if (!System.getProperties().containsKey("cassandra.truststore.password")) {
- System.setProperty("cassandra.truststore.password", CassandraUtils.getTruststorePassword());
+
+ if (!System.getProperties().containsKey(PASSWORD_PROPERTY_NAME)) {
+ System.setProperty(PASSWORD_PROPERTY_NAME, CassandraUtils.getPassword());
}
- if (!System.getProperties().containsKey("cassandra.user")) {
- System.setProperty("cassandra.user", CassandraUtils.getUser());
+
+ if (!System.getProperties().containsKey(KEYSPACE_PROPERTY_NAME)) {
+ System.setProperty(KEYSPACE_PROPERTY_NAME, ZUSAMMEN);
}
- if (!System.getProperties().containsKey("cassandra.password")) {
- System.setProperty("cassandra.password", CassandraUtils.getPassword());
+
+
+ if (!System.getProperties().containsKey(DATA_CENTER_PROPERTY_NAME)) {
+ String dataCenter = CassandraUtils.getLocalDataCenter();
+ if (Objects.nonNull(dataCenter)) {
+ System.setProperty(DATA_CENTER_PROPERTY_NAME, dataCenter);
+ }
}
- if (!System.getProperties().containsKey("cassandra.keyspace")) {
- System.setProperty("cassandra.keyspace", "zusammen");
+
+ if (!System.getProperties().containsKey(CONSISTENCY_LEVEL_PROPERTY_NAME)) {
+ String consistencyLevel = CassandraUtils.getConsistencyLevel();
+ if (Objects.nonNull(consistencyLevel)) {
+ System.setProperty(CONSISTENCY_LEVEL_PROPERTY_NAME, consistencyLevel);
+ }
}
+
+
}
// -Dcassandra.nodes=10.147.97.145 -Dcassandra.keyspace=zusammen -Dcassandra.authenticate=true -Dcassandra.ssl=true