diff options
Diffstat (limited to 'openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/src')
-rw-r--r-- | openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/src/main/java/org/openecomp/core/zusammen/impl/CassandraConnectionInitializer.java | 136 |
1 files changed, 63 insertions, 73 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 index 8eeeb1e27b..7944999a70 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 @@ -16,85 +16,75 @@ package org.openecomp.core.zusammen.impl; +import java.util.function.Supplier; import org.apache.commons.lang3.StringUtils; - import org.openecomp.core.nosqldb.util.CassandraUtils; -import java.util.function.Supplier; - -import javax.servlet.ServletContextEvent; -import javax.servlet.ServletContextListener; - -public class CassandraConnectionInitializer implements ServletContextListener { - - private static final String CASSANDRA_PREFIX = "cassandra."; - private static final String DATA_CENTER_PROPERTY_NAME = CASSANDRA_PREFIX + "datacenter"; - private static final String CONSISTENCY_LEVEL_PROPERTY_NAME = - CASSANDRA_PREFIX + "consistency.level"; - private static final String NODES_PROPERTY_NAME = CASSANDRA_PREFIX + "nodes"; - private static final String AUTHENTICATE_PROPERTY_NAME = CASSANDRA_PREFIX + "authenticate"; - private static final String SSL_PROPERTY_NAME = CASSANDRA_PREFIX + "ssl"; - private static final String TRUSTSTORE_PROPERTY_NAME = CASSANDRA_PREFIX + "truststore"; - private static final String TRUSTSTORE_PASSWORD_PROPERTY_NAME = - CASSANDRA_PREFIX + "truststore.password"; - private static final String USER_PROPERTY_NAME = CASSANDRA_PREFIX + "user"; - private static final String PASSWORD_PROPERTY_NAME = CASSANDRA_PREFIX + "password"; - private static final String KEYSPACE_PROPERTY_NAME = CASSANDRA_PREFIX + "keyspace"; - private static final String ZUSAMMEN = "zusammen"; - - @Override - public void contextInitialized(ServletContextEvent servletContextEvent) { - setCassandraConnectionPropertiesToSystem(); - } - - public static void setCassandraConnectionPropertiesToSystem() { - DeferredInitializer.init(); - } - - @Override - public void contextDestroyed(ServletContextEvent servletContextEvent) { - // no-op, required by the interface - } - - private static class DeferredInitializer { - - static { - setSystemProperty(NODES_PROPERTY_NAME, () -> - StringUtils.join(CassandraUtils.getAddresses(), ',')); - setBooleanSystemProperty(AUTHENTICATE_PROPERTY_NAME, CassandraUtils::isAuthenticate); - setBooleanSystemProperty(SSL_PROPERTY_NAME, CassandraUtils::isSsl); - setSystemProperty(TRUSTSTORE_PROPERTY_NAME, CassandraUtils::getTruststore); - setSystemProperty(TRUSTSTORE_PASSWORD_PROPERTY_NAME, CassandraUtils::getTruststorePassword); - setSystemProperty(USER_PROPERTY_NAME, CassandraUtils::getUser); - setSystemProperty(PASSWORD_PROPERTY_NAME, CassandraUtils::getPassword); - setSystemProperty(KEYSPACE_PROPERTY_NAME, () -> ZUSAMMEN); - setNullableSystemProperty(DATA_CENTER_PROPERTY_NAME, CassandraUtils::getLocalDataCenter); - setNullableSystemProperty(CONSISTENCY_LEVEL_PROPERTY_NAME, - CassandraUtils::getConsistencyLevel); - } - - private static void setSystemProperty(String name, Supplier<String> valueSupplier) { - - if (System.getProperty(name) == null) { - System.setProperty(name, valueSupplier.get()); - } +public class CassandraConnectionInitializer { + + private static final String CASSANDRA_PREFIX = "cassandra."; + private static final String DATA_CENTER_PROPERTY_NAME = CASSANDRA_PREFIX + "datacenter"; + private static final String CONSISTENCY_LEVEL_PROPERTY_NAME = + CASSANDRA_PREFIX + "consistency.level"; + private static final String NODES_PROPERTY_NAME = CASSANDRA_PREFIX + "nodes"; + private static final String AUTHENTICATE_PROPERTY_NAME = CASSANDRA_PREFIX + "authenticate"; + private static final String SSL_PROPERTY_NAME = CASSANDRA_PREFIX + "ssl"; + private static final String TRUSTSTORE_PROPERTY_NAME = CASSANDRA_PREFIX + "truststore"; + private static final String TRUSTSTORE_PASSWORD_PROPERTY_NAME = + CASSANDRA_PREFIX + "truststore.password"; + private static final String USER_PROPERTY_NAME = CASSANDRA_PREFIX + "user"; + private static final String PASSWORD_PROPERTY_NAME = CASSANDRA_PREFIX + "password"; + private static final String KEYSPACE_PROPERTY_NAME = CASSANDRA_PREFIX + "keyspace"; + private static final String ZUSAMMEN = "zusammen"; + + private CassandraConnectionInitializer() { + // static utility class, prevent instantiation } - private static void setBooleanSystemProperty(String name, Supplier<Boolean> valueSupplier) { - setSystemProperty(name, () -> Boolean.toString(valueSupplier.get())); + public static void setCassandraConnectionPropertiesToSystem() { + DeferredInitializer.init(); } - private static void setNullableSystemProperty(String name, Supplier<String> valueSupplier) { - - if ((System.getProperty(name) == null) && (valueSupplier.get() != null)) { - System.setProperty(name, valueSupplier.get()); - } - } - - private DeferredInitializer() { } - - public static void init() { - // just to ensure static initialization + private static class DeferredInitializer { + + static { + setSystemProperty(NODES_PROPERTY_NAME, () -> + StringUtils.join(CassandraUtils.getAddresses(), ',')); + setBooleanSystemProperty(AUTHENTICATE_PROPERTY_NAME, CassandraUtils::isAuthenticate); + setBooleanSystemProperty(SSL_PROPERTY_NAME, CassandraUtils::isSsl); + setSystemProperty(TRUSTSTORE_PROPERTY_NAME, CassandraUtils::getTruststore); + setSystemProperty(TRUSTSTORE_PASSWORD_PROPERTY_NAME, CassandraUtils::getTruststorePassword); + setSystemProperty(USER_PROPERTY_NAME, CassandraUtils::getUser); + setSystemProperty(PASSWORD_PROPERTY_NAME, CassandraUtils::getPassword); + setSystemProperty(KEYSPACE_PROPERTY_NAME, () -> ZUSAMMEN); + setNullableSystemProperty(DATA_CENTER_PROPERTY_NAME, CassandraUtils::getLocalDataCenter); + setNullableSystemProperty(CONSISTENCY_LEVEL_PROPERTY_NAME, + CassandraUtils::getConsistencyLevel); + } + + private DeferredInitializer() { } + + @SuppressWarnings("EmptyMethod") + static void init() { + // no-op, just to ensure static initialization + } + + private static void setSystemProperty(String name, Supplier<String> valueSupplier) { + + if (System.getProperty(name) == null) { + System.setProperty(name, valueSupplier.get()); + } + } + + private static void setBooleanSystemProperty(String name, Supplier<Boolean> valueSupplier) { + setSystemProperty(name, () -> Boolean.toString(valueSupplier.get())); + } + + private static void setNullableSystemProperty(String name, Supplier<String> valueSupplier) { + + if ((System.getProperty(name) == null) && (valueSupplier.get() != null)) { + System.setProperty(name, valueSupplier.get()); + } + } } - } } |