Update to spring boot 2

Update of dependencies and source code to spring boot 2

Issue-ID: AAI-3140
Signed-off-by: Igor Dysko <igor1.dysko@orange.com>
Change-Id: I4b386ef27b726ffd47b3515b0df05dc404e55943

17 files changed, 122 insertions, 87 deletions

diff --git a/src/main/java/org/onap/aai/cacher/Application.java b/src/main/java/org/onap/aai/cacher/Application.java
index 6d40b68..e2dbca9 100644
--- a/src/main/java/org/onap/aai/cacher/Application.java
+++ b/src/main/java/org/onap/aai/cacher/Application.java
@@ -28,9 +28,10 @@ import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
+import org.springframework.boot.autoconfigure.mongo.embedded.EmbeddedMongoAutoConfiguration;
 import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration;
 import org.springframework.boot.builder.SpringApplicationBuilder;
-import org.springframework.boot.web.support.SpringBootServletInitializer;
+import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
@@ -39,7 +40,7 @@ import java.util.UUID;
 
 @SpringBootApplication
 @EnableScheduling
-@EnableAutoConfiguration(exclude = { DataSourceAutoConfiguration.class, HibernateJpaAutoConfiguration.class })
+@EnableAutoConfiguration(exclude = { DataSourceAutoConfiguration.class, HibernateJpaAutoConfiguration.class, EmbeddedMongoAutoConfiguration.class})
 @ComponentScan(basePackages = { "org.onap.aai.cacher", "com" })
 public class Application extends SpringBootServletInitializer {
 
@@ -65,7 +66,7 @@ public class Application extends SpringBootServletInitializer {
         LoggingContext.statusCode(StatusCode.COMPLETE);
 
         SpringApplication app = new SpringApplication(Application.class);
-        app.setLogStartupInfo(false);
+        app.setLogStartupInfo(true);
         app.setRegisterShutdownHook(true);
         app.addInitializers(new PropertyPasswordConfiguration());
         app.run(args);
diff --git a/src/main/java/org/onap/aai/cacher/common/MongoConfig.java b/src/main/java/org/onap/aai/cacher/common/MongoConfig.java
index ca063a7..854437d 100644
--- a/src/main/java/org/onap/aai/cacher/common/MongoConfig.java
+++ b/src/main/java/org/onap/aai/cacher/common/MongoConfig.java
@@ -28,7 +28,10 @@ import de.flapdoodle.embed.mongo.Command;
 import de.flapdoodle.embed.mongo.MongodExecutable;
 import de.flapdoodle.embed.mongo.MongodProcess;
 import de.flapdoodle.embed.mongo.MongodStarter;
-import de.flapdoodle.embed.mongo.config.*;
+import de.flapdoodle.embed.mongo.config.Defaults;
+import de.flapdoodle.embed.mongo.config.MongoCmdOptions;
+import de.flapdoodle.embed.mongo.config.MongodConfig;
+import de.flapdoodle.embed.mongo.config.Net;
 import de.flapdoodle.embed.mongo.distribution.Version;
 import de.flapdoodle.embed.process.config.io.ProcessOutput;
 import de.flapdoodle.embed.process.io.Processors;
@@ -50,11 +53,11 @@ public class MongoConfig {
 
     private static final EELFLogger EELF_LOGGER = EELFManager.getInstance().getLogger(MongoConfig.class);
 
-    @Value("${mongodb.host}")
+    @Value("${spring.data.mongodb.host}")
     private String MONGO_DB_HOST;
-    @Value("${mongodb.dbName}")
+    @Value("${spring.data.mongodb.database}")
     private String MONGO_DB_NAME;
-    @Value("${mongodb.port}")
+    @Value("${spring.data.mongodb.port}")
     private int MONGO_DB_PORT;
 
     private MongodProcess mongod;
@@ -93,19 +96,18 @@ public class MongoConfig {
         Logger logger = LoggerFactory.getLogger("mongo");
         int port = MONGO_DB_PORT;
 
-        IMongodConfig mongoConfigConfig = new MongodConfigBuilder()
+        MongodConfig mongoConfigConfig = MongodConfig.builder()
                 .version(Version.Main.PRODUCTION)
                 .net(new Net(port, Network.localhostIsIPv6()))
-                .cmdOptions(new MongoCmdOptionsBuilder().enableTextSearch(true).useNoPrealloc(false).build())
-                .configServer(false)
+                .cmdOptions(MongoCmdOptions.builder().enableTextSearch(true).useNoPrealloc(false).build())
+                .isConfigServer(false)
                 .build();
 
         ProcessOutput processOutput = new ProcessOutput(Processors.logTo(logger, Slf4jLevel.WARN), Processors.logTo(logger,
                 Slf4jLevel.WARN), Processors.logTo(logger, Slf4jLevel.WARN));
 
         MongodExecutable mongodExecutable = MongodStarter
-                .getInstance((new RuntimeConfigBuilder())
-                        .defaults(Command.MongoD)
+                .getInstance(Defaults.runtimeConfigFor(Command.MongoD)
                         .processOutput(processOutput)
                         .build())
                 .prepare(mongoConfigConfig);
diff --git a/src/main/java/org/onap/aai/cacher/injestion/parser/strategy/aai/AAIResourcesUriTemplates.java b/src/main/java/org/onap/aai/cacher/injestion/parser/strategy/aai/AAIResourcesUriTemplates.java
index 819a7a6..0a4c931 100644
--- a/src/main/java/org/onap/aai/cacher/injestion/parser/strategy/aai/AAIResourcesUriTemplates.java
+++ b/src/main/java/org/onap/aai/cacher/injestion/parser/strategy/aai/AAIResourcesUriTemplates.java
@@ -227,11 +227,7 @@ public class AAIResourcesUriTemplates {
      * @return
      */
     public String encodeProp(String string) {
-        try {
-            return UriUtils.encode(string, "UTF-8");
-        } catch (UnsupportedEncodingException e) {
-            return "";
-        }
+        return UriUtils.encode(string, "UTF-8");
     }
 
     /**
@@ -241,11 +237,7 @@ public class AAIResourcesUriTemplates {
      * @return
      */
     public String decodeProp(String string) {
-        try {
-            return UriUtils.decode(string, "UTF-8");
-        } catch (UnsupportedEncodingException e) {
-            return "";
-        }
+        return UriUtils.decode(string, "UTF-8");
     }
 
     public String getAAIUriFromEntityUri(String fullUri) {
diff --git a/src/main/java/org/onap/aai/cacher/service/tasks/ScheduledTaskConfig.java b/src/main/java/org/onap/aai/cacher/service/tasks/ScheduledTaskConfig.java
index cdd9a2c..3f09124 100644
--- a/src/main/java/org/onap/aai/cacher/service/tasks/ScheduledTaskConfig.java
+++ b/src/main/java/org/onap/aai/cacher/service/tasks/ScheduledTaskConfig.java
@@ -42,7 +42,7 @@ public class ScheduledTaskConfig {
     private static final int TASK_INTERVAL_TIME = 30000;
     private static final int TASK_DELAY_TIME = 0;
 
-    private ScheduledTaskConfig(){}
+    //private ScheduledTaskConfig(){}
 
     @Configuration
     static class RegisterTaskSchedulerViaSchedulingConfigurer implements SchedulingConfigurer {
diff --git a/src/main/java/org/onap/aai/cacher/util/RestClient.java b/src/main/java/org/onap/aai/cacher/util/RestClient.java
index 9613d81..f836287 100644
--- a/src/main/java/org/onap/aai/cacher/util/RestClient.java
+++ b/src/main/java/org/onap/aai/cacher/util/RestClient.java
@@ -125,7 +125,7 @@ public class RestClient {
 
     @Bean
     RestTemplate restTemplate(RestTemplateBuilder builder) throws Exception {
-        RestTemplate restTemplate = builder.requestFactory(new HttpComponentsClientHttpRequestFactory(restClient))
+        RestTemplate restTemplate = builder.requestFactory(() -> new HttpComponentsClientHttpRequestFactory(restClient))
                 .build();
 
         restTemplate.setErrorHandler(new ResponseErrorHandler() {
diff --git a/src/main/java/org/onap/aai/cacher/web/JerseyConfiguration.java b/src/main/java/org/onap/aai/cacher/web/JerseyConfiguration.java
index b18e840..d0a15cd 100644
--- a/src/main/java/org/onap/aai/cacher/web/JerseyConfiguration.java
+++ b/src/main/java/org/onap/aai/cacher/web/JerseyConfiguration.java
@@ -19,7 +19,7 @@
  */
 package org.onap.aai.cacher.web;
 
-import org.glassfish.jersey.filter.LoggingFilter;
+import org.glassfish.jersey.logging.LoggingFeature;
 import org.glassfish.jersey.server.ResourceConfig;
 import org.onap.aai.cacher.service.rest.CacheInteractionService;
 import org.onap.aai.cacher.service.rest.CacheKeyService;
@@ -60,7 +60,7 @@ public class JerseyConfiguration extends ResourceConfig {
         // If the LoggingFilter second argument is set to true, it will print response
         // value as well
         if ("true".equalsIgnoreCase(env.getProperty("aai.request.logging.enabled"))) {
-            register(new LoggingFilter(log, false));
+            register(new LoggingFeature(log, 0));
         }
     }
 
diff --git a/src/main/java/org/onap/aai/cacher/web/LocalHostAccessLog.java b/src/main/java/org/onap/aai/cacher/web/LocalHostAccessLog.java
index 81addb5..ff7d79f 100644
--- a/src/main/java/org/onap/aai/cacher/web/LocalHostAccessLog.java
+++ b/src/main/java/org/onap/aai/cacher/web/LocalHostAccessLog.java
@@ -22,9 +22,9 @@ package org.onap.aai.cacher.web;
 import ch.qos.logback.access.jetty.RequestLogImpl;
 import org.eclipse.jetty.server.handler.HandlerCollection;
 import org.eclipse.jetty.server.handler.RequestLogHandler;
-import org.springframework.boot.context.embedded.EmbeddedServletContainerFactory;
-import org.springframework.boot.context.embedded.jetty.JettyEmbeddedServletContainerFactory;
-import org.springframework.boot.context.embedded.jetty.JettyServerCustomizer;
+import org.springframework.boot.web.embedded.jetty.JettyServerCustomizer;
+import org.springframework.boot.web.embedded.jetty.JettyServletWebServerFactory;
+import org.springframework.boot.web.servlet.server.AbstractServletWebServerFactory;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -34,8 +34,8 @@ import java.util.Arrays;
 public class LocalHostAccessLog {
 
     @Bean
-    public EmbeddedServletContainerFactory jettyConfigBean() {
-        JettyEmbeddedServletContainerFactory jef = new JettyEmbeddedServletContainerFactory();
+    public AbstractServletWebServerFactory jettyConfigBean() {
+        JettyServletWebServerFactory jef = new JettyServletWebServerFactory();
         jef.addServerCustomizers((JettyServerCustomizer) server -> {
 
             HandlerCollection handlers = new HandlerCollection();
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
index cd51b92..1937032 100644
--- a/src/main/resources/application.properties
+++ b/src/main/resources/application.properties
@@ -8,7 +8,7 @@ spring.jersey.type=filter
 spring.mvc.urls=swagger,docs,prometheus
 
 
-server.contextPath=/
+server.servlet.context-path=/
 spring.autoconfigure.exclude=org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration,org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration
 
 spring.profiles.active=production,one-way-ssl
@@ -36,7 +36,7 @@ archetype.name=sdk-java-jersey-archetype
 server.local.startpath=src/main/resources/
 server.basic.auth.location=${server.local.startpath}etc/auth/realm.properties
 
-server.port = 8444
+server.port=8444
 server.ssl.enabled-protocols=TLSv1.1,TLSv1.2
 server.ssl.key-store=${server.local.startpath}etc/auth/aai_keystore
 server.ssl.key-store-password=password(OBF:1vn21ugu1saj1v9i1v941sar1ugw1vo0)
@@ -46,9 +46,9 @@ server.ssl.client-auth=want
 server.ssl.key-store-type=JKS
 
 #mongodb configuration values
-mongodb.host=localhost
-mongodb.dbName=aai
-mongodb.port=27017
+spring.data.mongodb.host=localhost
+spring.data.mongodb.database=aai
+spring.data.mongodb.port=27017
 
 #logging configurations
 aai.transaction.logging=true
diff --git a/src/test/java/org/onap/aai/cacher/common/LimitTest.java b/src/test/java/org/onap/aai/cacher/common/LimitTest.java
index 366181d..2753ca2 100644
--- a/src/test/java/org/onap/aai/cacher/common/LimitTest.java
+++ b/src/test/java/org/onap/aai/cacher/common/LimitTest.java
@@ -30,7 +30,10 @@ import de.flapdoodle.embed.mongo.Command;
 import de.flapdoodle.embed.mongo.MongodExecutable;
 import de.flapdoodle.embed.mongo.MongodProcess;
 import de.flapdoodle.embed.mongo.MongodStarter;
-import de.flapdoodle.embed.mongo.config.*;
+import de.flapdoodle.embed.mongo.config.Defaults;
+import de.flapdoodle.embed.mongo.config.MongoCmdOptions;
+import de.flapdoodle.embed.mongo.config.MongodConfig;
+import de.flapdoodle.embed.mongo.config.Net;
 import de.flapdoodle.embed.mongo.distribution.Version;
 import de.flapdoodle.embed.process.config.io.ProcessOutput;
 import de.flapdoodle.embed.process.io.Processors;
@@ -111,19 +114,18 @@ public class LimitTest {
 	protected static void startEmbedded(int port) throws IOException {
 		Logger logger = LoggerFactory.getLogger("mongo");
 
-		IMongodConfig mongoConfigConfig = new MongodConfigBuilder()
+		MongodConfig mongoConfigConfig = MongodConfig.builder()
 				.version(Version.Main.PRODUCTION)
 				.net(new Net(port, Network.localhostIsIPv6()))
-				.cmdOptions(new MongoCmdOptionsBuilder().enableTextSearch(true).useNoPrealloc(false).build())
-				.configServer(false)
+				.cmdOptions(MongoCmdOptions.builder().enableTextSearch(true).useNoPrealloc(false).build())
+				.isConfigServer(false)
 				.build();
 
 		ProcessOutput processOutput = new ProcessOutput(Processors.logTo(logger, Slf4jLevel.WARN), Processors.logTo(logger,
 				Slf4jLevel.WARN), Processors.logTo(logger, Slf4jLevel.WARN));
 
 		MongodExecutable mongodExecutable = MongodStarter
-				.getInstance((new RuntimeConfigBuilder())
-						.defaults(Command.MongoD)
+				.getInstance(Defaults.runtimeConfigFor(Command.MongoD)
 						.processOutput(processOutput)
 						.build())
 				.prepare(mongoConfigConfig);
diff --git a/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonNoFakeTest.java b/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonNoFakeTest.java
index 3f236a2..52ef9c6 100644
--- a/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonNoFakeTest.java
+++ b/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonNoFakeTest.java
@@ -83,19 +83,18 @@ public class MongoHelperSingletonNoFakeTest {
 	protected static void startEmbedded(int port) throws IOException {
 		Logger logger = LoggerFactory.getLogger("mongo");
 
-		IMongodConfig mongoConfigConfig = new MongodConfigBuilder()
+		MongodConfig mongoConfigConfig = MongodConfig.builder()
 				.version(Version.Main.PRODUCTION)
 				.net(new Net(port, Network.localhostIsIPv6()))
-				.cmdOptions(new MongoCmdOptionsBuilder().enableTextSearch(true).useNoPrealloc(false).build())
-				.configServer(false)
+				.cmdOptions(MongoCmdOptions.builder().enableTextSearch(true).useNoPrealloc(false).build())
+				.isConfigServer(false)
 				.build();
 
 		ProcessOutput processOutput = new ProcessOutput(Processors.logTo(logger, Slf4jLevel.WARN), Processors.logTo(logger,
 				Slf4jLevel.WARN), Processors.logTo(logger, Slf4jLevel.WARN));
 
 		MongodExecutable mongodExecutable = MongodStarter
-				.getInstance((new RuntimeConfigBuilder())
-						.defaults(Command.MongoD)
+				.getInstance(Defaults.runtimeConfigFor(Command.MongoD)
 						.processOutput(processOutput)
 						.build())
 				.prepare(mongoConfigConfig);
diff --git a/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonTest.java b/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonTest.java
index 872f099..b458b29 100644
--- a/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonTest.java
+++ b/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonTest.java
@@ -19,12 +19,15 @@
  */
 package org.onap.aai.cacher.common;
 
-import com.github.fakemongo.Fongo;
 import com.google.gson.JsonParser;
 import com.mongodb.DB;
+import com.mongodb.MongoClient;
+import com.mongodb.ServerAddress;
 import com.mongodb.client.MongoCollection;
 import com.mongodb.client.MongoDatabase;
 import com.mongodb.client.model.UpdateOptions;
+import de.bwaldvogel.mongo.MongoServer;
+import de.bwaldvogel.mongo.backend.memory.MemoryBackend;
 import org.bson.Document;
 import org.json.JSONException;
 import org.json.JSONObject;
@@ -36,6 +39,7 @@ import org.onap.aai.cacher.model.CacheEntry;
 import org.onap.aai.cacher.model.DBAction;
 import org.skyscreamer.jsonassert.JSONAssert;
 
+import java.net.InetSocketAddress;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Optional;
@@ -54,9 +58,12 @@ public class MongoHelperSingletonTest {
 
 	@BeforeClass
 	public static void setup() {
-		Fongo fongo = new Fongo(DB_NAME);
-		mongoDatabase = fongo.getDatabase(DB_NAME);
-		db = fongo.getDB(DB_NAME);
+		MongoServer mongoServer = new MongoServer(new MemoryBackend());
+		InetSocketAddress serverAddress = mongoServer.bind();
+
+		MongoClient client = new MongoClient(new ServerAddress(serverAddress));
+		mongoDatabase = client.getDatabase(DB_NAME);
+		db = client.getDB(DB_NAME);
 	}
 
 	@Before
@@ -169,7 +176,6 @@ public class MongoHelperSingletonTest {
 				.getClass()
 				.getEnclosingMethod()
 				.getName();
-		setupCollection(collectionName);
 
 		MongoCollection<Document> collection = setupCollection(collectionName);
 
@@ -193,7 +199,6 @@ public class MongoHelperSingletonTest {
 				.getClass()
 				.getEnclosingMethod()
 				.getName();
-		setupCollection(collectionName);
 
 		MongoCollection<Document> collection = setupCollection(collectionName);
 
@@ -224,7 +229,6 @@ public class MongoHelperSingletonTest {
 				.getClass()
 				.getEnclosingMethod()
 				.getName();
-		setupCollection(collectionName);
 
 		MongoCollection<Document> collection = setupCollection(collectionName);
 
@@ -258,7 +262,6 @@ public class MongoHelperSingletonTest {
 				.getClass()
 				.getEnclosingMethod()
 				.getName();
-		setupCollection(collectionName);
 
 		MongoCollection<Document> collection = setupCollection(collectionName);
 
@@ -295,7 +298,6 @@ public class MongoHelperSingletonTest {
 				.getClass()
 				.getEnclosingMethod()
 				.getName();
-		setupCollection(collectionName);
 
 		MongoCollection<Document> collection = setupCollection(collectionName);
 
diff --git a/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIDmaapEventProcessorScenariosTest.java b/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIDmaapEventProcessorScenariosTest.java
index c5d39a0..6139fb5 100644
--- a/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIDmaapEventProcessorScenariosTest.java
+++ b/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIDmaapEventProcessorScenariosTest.java
@@ -19,13 +19,15 @@
  */
 package org.onap.aai.cacher.dmaap.consumer;
 
-import com.github.fakemongo.Fongo;
 import com.google.gson.JsonArray;
 import com.google.gson.JsonObject;
 import com.google.gson.JsonParser;
 import com.mongodb.DB;
 import com.mongodb.MongoClient;
+import com.mongodb.ServerAddress;
 import com.mongodb.client.MongoDatabase;
+import de.bwaldvogel.mongo.MongoServer;
+import de.bwaldvogel.mongo.backend.memory.MemoryBackend;
 import de.flapdoodle.embed.mongo.MongodProcess;
 import org.apache.commons.io.IOUtils;
 import org.bson.Document;
@@ -49,6 +51,7 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 import java.io.IOException;
 import java.io.InputStream;
+import java.net.InetSocketAddress;
 import java.net.URI;
 import java.util.ArrayList;
 import java.util.List;
@@ -100,9 +103,12 @@ public class AAIDmaapEventProcessorScenariosTest {
 
 	@BeforeClass
 	public static void setup() throws IOException, InterruptedException {
-		Fongo fongo = new Fongo(DB_NAME);
-		mongoDb = fongo.getDatabase(DB_NAME);
-		db = fongo.getDB(DB_NAME);
+		MongoServer mongoServer = new MongoServer(new MemoryBackend());
+		InetSocketAddress serverAddress = mongoServer.bind();
+
+		MongoClient client = new MongoClient(new ServerAddress(serverAddress));
+		mongoDb = client.getDatabase(DB_NAME);
+		db = client.getDB(DB_NAME);
 	}
 
 	@AfterClass
diff --git a/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIEventConsumerTest.java b/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIEventConsumerTest.java
index 12d1416..c4a69c9 100644
--- a/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIEventConsumerTest.java
+++ b/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIEventConsumerTest.java
@@ -20,10 +20,12 @@
 package org.onap.aai.cacher.dmaap.consumer;
 
 import com.att.nsa.mr.client.MRConsumer;
-import com.github.fakemongo.Fongo;
 import com.mongodb.DB;
 import com.mongodb.MongoClient;
+import com.mongodb.ServerAddress;
 import com.mongodb.client.MongoDatabase;
+import de.bwaldvogel.mongo.MongoServer;
+import de.bwaldvogel.mongo.backend.memory.MemoryBackend;
 import de.flapdoodle.embed.mongo.MongodProcess;
 import org.hamcrest.Matchers;
 import org.junit.*;
@@ -41,6 +43,7 @@ import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 import java.io.IOException;
+import java.net.InetSocketAddress;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Properties;
@@ -48,7 +51,6 @@ import java.util.Properties;
 import static org.junit.Assert.assertNotEquals;
 import static org.junit.Assert.assertThat;
 
-//@Ignore
 @RunWith(SpringJUnit4ClassRunner.class)
 @Configuration
 @ContextConfiguration(classes = {InjestionTestComponent.class, AAIEventConsumerTest.class})
@@ -100,9 +102,13 @@ public class AAIEventConsumerTest  {
 
 	@BeforeClass
 	public static void setup() throws IOException, InterruptedException {
-		Fongo fongo = new Fongo(DB_NAME);
-		mongoDb = fongo.getDatabase(DB_NAME);
-		db = fongo.getDB(DB_NAME);
+
+		MongoServer mongoServer = new MongoServer(new MemoryBackend());
+		InetSocketAddress serverAddress = mongoServer.bind();
+
+		MongoClient client = new MongoClient(new ServerAddress(serverAddress));
+		mongoDb = client.getDatabase(DB_NAME);
+		db = client.getDB(DB_NAME);
 	}
 	
 	@Before
diff --git a/src/test/java/org/onap/aai/cacher/injestion/parser/AAIResourcesUriTemplatesTest.java b/src/test/java/org/onap/aai/cacher/injestion/parser/AAIResourcesUriTemplatesTest.java
index d093b6c..8a888dc 100644
--- a/src/test/java/org/onap/aai/cacher/injestion/parser/AAIResourcesUriTemplatesTest.java
+++ b/src/test/java/org/onap/aai/cacher/injestion/parser/AAIResourcesUriTemplatesTest.java
@@ -19,10 +19,12 @@
  */
 package org.onap.aai.cacher.injestion.parser;
 
-import com.github.fakemongo.Fongo;
 import com.mongodb.DB;
 import com.mongodb.MongoClient;
+import com.mongodb.ServerAddress;
 import com.mongodb.client.MongoDatabase;
+import de.bwaldvogel.mongo.MongoServer;
+import de.bwaldvogel.mongo.backend.memory.MemoryBackend;
 import de.flapdoodle.embed.mongo.MongodProcess;
 import org.junit.After;
 import org.junit.AfterClass;
@@ -38,6 +40,7 @@ import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 import java.io.IOException;
+import java.net.InetSocketAddress;
 import java.util.*;
 
 import static org.hamcrest.CoreMatchers.is;
@@ -74,9 +77,12 @@ public class AAIResourcesUriTemplatesTest {
 
 	@BeforeClass
 	public static void setup() throws IOException, InterruptedException {
-		Fongo fongo = new Fongo(DB_NAME);
-		mongoDb = fongo.getDatabase(DB_NAME);
-		db = fongo.getDB(DB_NAME);
+		MongoServer mongoServer = new MongoServer(new MemoryBackend());
+		InetSocketAddress serverAddress = mongoServer.bind();
+
+		MongoClient client = new MongoClient(new ServerAddress(serverAddress));
+		mongoDb = client.getDatabase(DB_NAME);
+		db = client.getDB(DB_NAME);
 	}
 
 	@AfterClass
diff --git a/src/test/java/org/onap/aai/cacher/injestion/parser/PayloadParserServiceTest.java b/src/test/java/org/onap/aai/cacher/injestion/parser/PayloadParserServiceTest.java
index ddac8e3..7ab8da7 100644
--- a/src/test/java/org/onap/aai/cacher/injestion/parser/PayloadParserServiceTest.java
+++ b/src/test/java/org/onap/aai/cacher/injestion/parser/PayloadParserServiceTest.java
@@ -19,20 +19,21 @@
  */
 package org.onap.aai.cacher.injestion.parser;
 
-import com.github.fakemongo.Fongo;
 import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
 import com.google.gson.JsonObject;
 import com.google.gson.JsonParser;
 import com.mongodb.DB;
 import com.mongodb.MongoClient;
+import com.mongodb.ServerAddress;
 import com.mongodb.client.MongoDatabase;
+import de.bwaldvogel.mongo.MongoServer;
+import de.bwaldvogel.mongo.backend.memory.MemoryBackend;
 import de.flapdoodle.embed.mongo.MongodExecutable;
 import de.flapdoodle.embed.mongo.MongodProcess;
 import de.flapdoodle.embed.mongo.MongodStarter;
-import de.flapdoodle.embed.mongo.config.IMongodConfig;
-import de.flapdoodle.embed.mongo.config.MongoCmdOptionsBuilder;
-import de.flapdoodle.embed.mongo.config.MongodConfigBuilder;
+import de.flapdoodle.embed.mongo.config.MongoCmdOptions;
+import de.flapdoodle.embed.mongo.config.MongodConfig;
 import de.flapdoodle.embed.mongo.config.Net;
 import de.flapdoodle.embed.mongo.distribution.Version;
 import de.flapdoodle.embed.process.runtime.Network;
@@ -51,6 +52,7 @@ import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 import java.io.IOException;
+import java.net.InetSocketAddress;
 import java.util.List;
 
 import static org.hamcrest.CoreMatchers.is;
@@ -107,17 +109,20 @@ public class PayloadParserServiceTest {
 
 	@BeforeClass
 	public static void setup() throws IOException, InterruptedException {
-		Fongo fongo = new Fongo(DB_NAME);
-		mongoDb = fongo.getDatabase(DB_NAME);
-		db = fongo.getDB(DB_NAME);
+		MongoServer mongoServer = new MongoServer(new MemoryBackend());
+		InetSocketAddress serverAddress = mongoServer.bind();
+
+		MongoClient client = new MongoClient(new ServerAddress(serverAddress));
+		mongoDb = client.getDatabase(DB_NAME);
+		db = client.getDB(DB_NAME);
 	}
 
 	protected static void startEmbedded(int port) throws IOException {
-		IMongodConfig mongoConfigConfig = new MongodConfigBuilder()
+		MongodConfig mongoConfigConfig = MongodConfig.builder()
 				.version(Version.Main.PRODUCTION)
 				.net(new Net(port, Network.localhostIsIPv6()))
-				.cmdOptions(new MongoCmdOptionsBuilder().verbose(true).build())
-				.configServer(false)
+				.cmdOptions(MongoCmdOptions.builder().isVerbose(true).build())
+				.isConfigServer(false)
 				.build();
 
 		MongodExecutable mongodExecutable = MongodStarter.getDefaultInstance().prepare(mongoConfigConfig);
diff --git a/src/test/java/org/onap/aai/cacher/service/helper/CacheHelperServiceScenariosTest.java b/src/test/java/org/onap/aai/cacher/service/helper/CacheHelperServiceScenariosTest.java
index 00beab6..7f2a952 100644
--- a/src/test/java/org/onap/aai/cacher/service/helper/CacheHelperServiceScenariosTest.java
+++ b/src/test/java/org/onap/aai/cacher/service/helper/CacheHelperServiceScenariosTest.java
@@ -19,10 +19,12 @@
  */
 package org.onap.aai.cacher.service.helper;
 
-import com.github.fakemongo.Fongo;
 import com.mongodb.DB;
 import com.mongodb.MongoClient;
+import com.mongodb.ServerAddress;
 import com.mongodb.client.MongoDatabase;
+import de.bwaldvogel.mongo.MongoServer;
+import de.bwaldvogel.mongo.backend.memory.MemoryBackend;
 import de.flapdoodle.embed.mongo.MongodProcess;
 import org.junit.After;
 import org.junit.AfterClass;
@@ -44,6 +46,7 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 import javax.ws.rs.core.Response;
 import java.io.IOException;
+import java.net.InetSocketAddress;
 import java.text.DateFormat;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
@@ -98,7 +101,7 @@ public class CacheHelperServiceScenariosTest {
 
 	@Bean
 	public RestClientHelperService restClientHelperService() {
-		return restClientHelperService;
+		return new RestClientHelperService();
 	}
 
 	@Bean
@@ -113,9 +116,12 @@ public class CacheHelperServiceScenariosTest {
 
 	@BeforeClass
 	public static void setup() throws IOException, InterruptedException {
-		Fongo fongo = new Fongo(DB_NAME);
-		mongoDb = fongo.getDatabase(DB_NAME);
-		db = fongo.getDB(DB_NAME);
+		MongoServer mongoServer = new MongoServer(new MemoryBackend());
+		InetSocketAddress serverAddress = mongoServer.bind();
+
+		MongoClient client = new MongoClient(new ServerAddress(serverAddress));
+		mongoDb = client.getDatabase(DB_NAME);
+		db = client.getDB(DB_NAME);
 	}
 
 	@AfterClass
diff --git a/src/test/java/org/onap/aai/cacher/service/helper/CrudOperationsTest.java b/src/test/java/org/onap/aai/cacher/service/helper/CrudOperationsTest.java
index 1aa1d81..3fce450 100644
--- a/src/test/java/org/onap/aai/cacher/service/helper/CrudOperationsTest.java
+++ b/src/test/java/org/onap/aai/cacher/service/helper/CrudOperationsTest.java
@@ -19,16 +19,21 @@
  */
 package org.onap.aai.cacher.service.helper;
 
-import com.github.fakemongo.Fongo;
+import com.mongodb.MongoClient;
+import com.mongodb.ServerAddress;
 import com.mongodb.client.FindIterable;
 import com.mongodb.client.MongoCollection;
 import com.mongodb.client.MongoDatabase;
 import com.mongodb.client.model.FindOneAndUpdateOptions;
 import com.mongodb.client.model.UpdateOptions;
+import de.bwaldvogel.mongo.MongoServer;
+import de.bwaldvogel.mongo.backend.memory.MemoryBackend;
 import org.bson.Document;
 import org.junit.BeforeClass;
 import org.junit.Test;
 
+import java.net.InetSocketAddress;
+
 import static org.junit.Assert.assertEquals;
 
 public class CrudOperationsTest {
@@ -38,8 +43,11 @@ public class CrudOperationsTest {
 
 	@BeforeClass
 	public static void setup() {
-		Fongo fongo = new Fongo(DB_NAME);
-		mongoDatabase = fongo.getDatabase(DB_NAME);
+		MongoServer mongoServer = new MongoServer(new MemoryBackend());
+		InetSocketAddress serverAddress = mongoServer.bind();
+
+		MongoClient client = new MongoClient(new ServerAddress(serverAddress));
+		mongoDatabase = client.getDatabase(DB_NAME);
 	}
 
 	@Test