X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fservice%2FMirrorMakerServiceTest.java;h=f247bad5c6dc74bcb4a0825f33581d7f8ba29c57;hb=refs%2Fchanges%2F65%2F84965%2F2;hp=787d232d7b4813b13173f335e89113fc3b03f4d0;hpb=479c7a5645b6f3f9bf478f925fa2009597871a7b;p=dmaap%2Fdbcapi.git

diff --git a/src/test/java/org/onap/dmaap/dbcapi/service/MirrorMakerServiceTest.java b/src/test/java/org/onap/dmaap/dbcapi/service/MirrorMakerServiceTest.java
index 787d232..f247bad 100644
--- a/src/test/java/org/onap/dmaap/dbcapi/service/MirrorMakerServiceTest.java
+++ b/src/test/java/org/onap/dmaap/dbcapi/service/MirrorMakerServiceTest.java
@@ -42,6 +42,9 @@ public class MirrorMakerServiceTest {
 	private MR_ClusterService mcs;
 	private MR_ClientService cls;
 	private DcaeLocationService dls;
+	
+	private Topic replicationTopic;
+
 
 	DmaapService ds;
 	String locname;
@@ -73,6 +76,24 @@ public class MirrorMakerServiceTest {
 		mcs.addMr_Cluster( node, err);
 		node = factory.genMR_Cluster("edge" );
 		mcs.addMr_Cluster(node,  err);
+
+
+		String t = "org.onap.dmaap.bridgingTopic";
+		replicationTopic = factory.genSimpleTopic(t);
+		replicationTopic.setReplicationCase( ReplicationType.REPLICATION_EDGE_TO_CENTRAL );
+
+		String c = "publisher";
+		String[] a = { "sub", "view" };
+		MR_Client sub = factory.genMR_Client("central",  replicationTopic.getFqtn(), c, a );
+		String[] b = { "pub", "view" };
+		MR_Client pub = factory.genMR_Client( "edge", replicationTopic.getFqtn(), c, b );
+		ArrayList<MR_Client> clients = new ArrayList<MR_Client>();
+
+		clients.add( sub );
+		clients.add( pub );
+
+		replicationTopic.setClients( clients );
+
 	}
 
 	@After
@@ -101,23 +122,8 @@ public class MirrorMakerServiceTest {
 	public void CreateMirrorMakerWithSingleTopic() {
 		ApiError err = new ApiError();
 
-		String t = "org.onap.dmaap.bridgingTopic";
-		Topic topic = factory.genSimpleTopic(t);
-		topic.setReplicationCase( ReplicationType.REPLICATION_EDGE_TO_CENTRAL );
-
-		String c = "publisher";
-		String[] a = { "sub", "view" };
-		MR_Client sub = factory.genMR_Client("central",  topic.getFqtn(), c, a );
-		String[] b = { "pub", "view" };
-		MR_Client pub = factory.genMR_Client( "edge", topic.getFqtn(), c, b );
-		ArrayList<MR_Client> clients = new ArrayList<MR_Client>();
-
-		clients.add( sub );
-		clients.add( pub );
-
-		topic.setClients( clients );
 
-		Topic nTopic = ts.updateTopic( topic, err );
+		Topic nTopic = ts.addTopic(replicationTopic, err, true );
 
 		assertTrue( err.getCode() == 200 );
 		
@@ -127,6 +133,13 @@ public class MirrorMakerServiceTest {
 	@Test
 	public void DeleteMirrorMakerWithSingleTopic() {
 
+		ApiError err = new ApiError();
+		Topic nTopic = ts.addTopic(replicationTopic, err, true );
+		replicationTopic.setTopicDescription("modified topic");
+		nTopic = ts.updateTopic( replicationTopic, err );
+
+		assertTrue( err.getCode() == 200 );
+
 		
 		List<String> mma = mms.getAllMirrorMakers();
 		
@@ -149,23 +162,11 @@ public class MirrorMakerServiceTest {
 
 		ApiError err = new ApiError();
 
-		String t = "org.onap.dmaap.bridgingTopic";
-		Topic topic = factory.genSimpleTopic(t);
-		topic.setReplicationCase( ReplicationType.REPLICATION_EDGE_TO_CENTRAL );
-
-		String c = "publisher";
-		String[] a = { "sub", "view" };
-		MR_Client sub = factory.genMR_Client("central",  topic.getFqtn(), c, a );
-		String[] b = { "pub", "view" };
-		MR_Client pub = factory.genMR_Client( "edge", topic.getFqtn(), c, b );
-		ArrayList<MR_Client> clients = new ArrayList<MR_Client>();
-
-		clients.add( sub );
-		clients.add( pub );
 
-		topic.setClients( clients );
+		Topic nTopic = ts.addTopic( replicationTopic, err, true );
+		replicationTopic.setTopicDescription("modified topic");
+		nTopic = ts.updateTopic( replicationTopic, err );
 
-		Topic nTopic = ts.updateTopic( topic, err );
 
 		assertTrue( err.getCode() == 200 );
 		List<String> mma = mms.getAllMirrorMakers();