X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fonap%2Fmusic%2Funittests%2FCassandraCQL.java;fp=src%2Ftest%2Fjava%2Forg%2Fonap%2Fmusic%2Funittests%2FCassandraCQL.java;h=4ae78236b548b87f8fbff32ffce67a2965032b98;hb=a27be9fdbbf2d271c9c5780ba70fe15a24dbdb63;hp=a4c250c2e3bac2436647e3bf0a4f031c89a1f268;hpb=95489883ce973e84267fcbcee685f1598d4bdd6e;p=music.git

diff --git a/src/test/java/org/onap/music/unittests/CassandraCQL.java b/src/test/java/org/onap/music/unittests/CassandraCQL.java
index a4c250c2..4ae78236 100644
--- a/src/test/java/org/onap/music/unittests/CassandraCQL.java
+++ b/src/test/java/org/onap/music/unittests/CassandraCQL.java
@@ -39,15 +39,16 @@ import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.UUID;
-import com.datastax.driver.core.Cluster;
-import com.datastax.driver.core.Session;
-import com.datastax.driver.core.exceptions.NoHostAvailableException;
-import org.apache.cassandra.exceptions.ConfigurationException;
-import org.apache.thrift.transport.TTransportException;
+
+//import org.apache.thrift.transport.TTransportException;
 import org.cassandraunit.utils.EmbeddedCassandraServerHelper;
 import org.onap.music.datastore.MusicDataStore;
 import org.onap.music.datastore.PreparedQueryObject;
 
+import com.datastax.driver.core.Cluster;
+import com.datastax.driver.core.Session;
+import com.datastax.driver.core.exceptions.NoHostAvailableException;
+
 public class CassandraCQL {
 
     public static final String createKeySpace =
@@ -232,14 +233,12 @@ public class CassandraCQL {
             try {
 
                 try {
-                    EmbeddedCassandraServerHelper.startEmbeddedCassandra(80000);
-                } catch (ConfigurationException | TTransportException | IOException e) {
-
-                    System.out.println(e.getMessage());
+                     EmbeddedCassandraServerHelper.startEmbeddedCassandra();
+                } catch (Exception e) {
+                         e.printStackTrace();
                 }
-
-                cluster = new Cluster.Builder().addContactPoint(address).withPort(9142).build();
-                cluster.getConfiguration().getSocketOptions().setReadTimeoutMillis(20000);
+                cluster = new Cluster.Builder().withoutJMXReporting().withoutMetrics().addContactPoint(address).withPort(9142).build();
+                cluster.getConfiguration().getSocketOptions().setReadTimeoutMillis(5000);
                 session = cluster.connect();
 
                 break;