1 files changed, 11 insertions, 5 deletions
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