diff options
Diffstat (limited to 'catalog-dao/src/main/java/org/openecomp/sdc/be/dao/cassandra/schema/SdcSchemaUtils.java')
-rw-r--r-- | catalog-dao/src/main/java/org/openecomp/sdc/be/dao/cassandra/schema/SdcSchemaUtils.java | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/cassandra/schema/SdcSchemaUtils.java b/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/cassandra/schema/SdcSchemaUtils.java index ca737b2a5d..434a6e6eab 100644 --- a/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/cassandra/schema/SdcSchemaUtils.java +++ b/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/cassandra/schema/SdcSchemaUtils.java @@ -20,19 +20,17 @@ package org.openecomp.sdc.be.dao.cassandra.schema; -import java.util.List; - +import com.datastax.driver.core.Cluster; +import com.datastax.driver.core.Session; import com.datastax.driver.core.SocketOptions; import org.openecomp.sdc.be.config.ConfigurationManager; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; +import org.openecomp.sdc.common.log.wrappers.Logger; -import com.datastax.driver.core.Cluster; -import com.datastax.driver.core.Session; +import java.util.List; public class SdcSchemaUtils { - private static Logger log = LoggerFactory.getLogger(SdcSchemaUtils.class.getName()); + private static Logger log = Logger.getLogger(SdcSchemaUtils.class.getName()); /** * the method creates the cluster object using the supplied cassandra nodes @@ -48,7 +46,7 @@ public class SdcSchemaUtils { } log.info("connecting to node:{}.", nodes); Cluster.Builder clusterBuilder = Cluster.builder(); - nodes.forEach(host -> clusterBuilder.addContactPoint(host)); + nodes.forEach(clusterBuilder::addContactPoint); clusterBuilder.withMaxSchemaAgreementWaitSeconds(60); |