add try catch arround mongo test factory to all tests

Author: Vasile Baluta

src/test/java/com/ericsson/ei/flowtests/FlowTestConfigs.java

@@ -6,8 +6,9 @@
 
 import java.io.File;
 import java.io.IOException;
-import java.net.ServerSocket;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.amqp.core.BindingBuilder;
 import org.springframework.amqp.core.Queue;
 import org.springframework.amqp.core.TopicExchange;
@@ -27,6 +28,8 @@ public class FlowTestConfigs {
     private RabbitAdmin admin;
     private ConnectionFactory cf;
 
+    final static Logger LOGGER = (Logger) LoggerFactory.getLogger(FlowTestConfigs.class);
+
     @Getter
     private Connection conn;
 
@@ -62,8 +65,13 @@ private void setUpMessageBus() throws Exception {
     }
 
     private void setUpEmbeddedMongo() throws IOException {
-        testsFactory = MongodForTestsFactory.with(Version.V3_4_1);
-        mongoClient = testsFactory.newMongo();
+        try {
+            testsFactory = MongodForTestsFactory.with(Version.V3_4_1);
+            mongoClient = testsFactory.newMongo();
+        } catch (Exception e) {
+            LOGGER.error(e.getMessage(), e);
+            e.printStackTrace();
+        }
         String port = "" + mongoClient.getAddress().getPort();
         System.setProperty("mongodb.port", port);
     }

src/test/java/com/ericsson/ei/mongoDBHandler/test/MongoDBHandlerTest.java

@@ -48,8 +48,13 @@ public class MongoDBHandlerTest {
     private String condition = "{\"test_cases.event_id\" : \"testcaseid1\"}";
 
     public void setUpEmbeddedMongo() throws Exception {
-        testsFactory = MongodForTestsFactory.with(Version.V3_4_1);
-        mongoClient = testsFactory.newMongo();
+        try {
+            testsFactory = MongodForTestsFactory.with(Version.V3_4_1);
+            mongoClient = testsFactory.newMongo();
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+            e.printStackTrace();
+        }
     }
 
     @Before

src/test/java/com/ericsson/ei/queryservice/test/QueryServiceTest.java

@@ -90,8 +90,13 @@ public class QueryServiceTest {
     private MongoDBHandler mongoDBHandler;
 
     public static void setUpEmbeddedMongo() throws Exception {
-        testsFactory = MongodForTestsFactory.with(Version.V3_4_1);
-        mongoClient = testsFactory.newMongo();
+        try {
+            testsFactory = MongodForTestsFactory.with(Version.V3_4_1);
+            mongoClient = testsFactory.newMongo();
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+            e.printStackTrace();
+        }
         String port = "" + mongoClient.getAddress().getPort();
         System.setProperty("mongodb.port", port);
 
@@ -101,7 +106,7 @@ public static void setUpEmbeddedMongo() throws Exception {
             missedNotification = FileUtils.readFileToString(new File(missedNotificationPath));
             System.out.println("The missedNotification is : " + missedNotification);
         } catch (Exception e) {
-            log.info(e.getMessage(), e);
+            log.error(e.getMessage(), e);
         }
     }
 

src/test/java/com/ericsson/ei/rules/test/TestRulesService.java

@@ -14,6 +14,8 @@
 import org.junit.BeforeClass;
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@@ -32,6 +34,8 @@ public class TestRulesService {
     private static final String RULES = "src/test/resources/AggregateListRules.json";
     private static final String AGGREGATED_RESULT_OBJECT = "src/test/resources/AggregateResultObject.json";
 
+    final static Logger LOGGER = (Logger) LoggerFactory.getLogger(TestRulesService.class);
+
     @Autowired
     private IRuleCheckService ruleCheckService;
 
@@ -43,8 +47,13 @@ public class TestRulesService {
 
     @BeforeClass
     public static void setMongoDB() throws IOException, JSONException {
-        testsFactory = MongodForTestsFactory.with(Version.V3_4_1);
-        mongoClient = testsFactory.newMongo();
+        try {
+            testsFactory = MongodForTestsFactory.with(Version.V3_4_1);
+            mongoClient = testsFactory.newMongo();
+        } catch (Exception e) {
+            LOGGER.error(e.getMessage(), e);
+            e.printStackTrace();
+        }
         String port = "" + mongoClient.getAddress().getPort();
         System.setProperty("mongodb.port", port);
     }

src/test/java/com/ericsson/ei/subscriptionhandler/test/SubscriptionHandlerTest.java

@@ -108,8 +108,13 @@ public class SubscriptionHandlerTest {
     private QueryResponse queryResponse;
 
     public static void setUpEmbeddedMongo() throws JSONException, IOException {
-        testsFactory = MongodForTestsFactory.with(Version.V3_4_1);
-        mongoClient = testsFactory.newMongo();
+        try {
+            testsFactory = MongodForTestsFactory.with(Version.V3_4_1);
+            mongoClient = testsFactory.newMongo();
+        } catch (Exception e) {
+            LOGGER.error(e.getMessage(), e);
+            e.printStackTrace();
+        }
         String port = "" + mongoClient.getAddress().getPort();
         System.setProperty("mongodb.port", port);
         aggregatedObject = FileUtils.readFileToString(new File(aggregatedPath), "UTF-8");