6c35b938c784e4815f896744136c64da28da8628
[dmaap/dbcapi.git] / src / test / java / org / onap / dmaap / dbcapi / model / MirrorMakerTest.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * org.onap.dmaap
4  * ================================================================================
5  * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
6  * ================================================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  * 
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  * 
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=========================================================
19  */
20 package org.onap.dmaap.dbcapi.model;
21
22 import static org.junit.Assert.*;
23
24 import org.junit.After;
25 import org.junit.Before;
26 import org.junit.Test;
27
28 import java.util.ArrayList;
29
30
31 public class MirrorMakerTest {
32
33         private static final String  fmt = "%24s: %s%n";
34
35         ReflectionHarness rh = new ReflectionHarness();
36
37
38         @Before
39         public void setUp() throws Exception {
40         }
41
42         @After
43         public void tearDown() throws Exception {
44         }
45
46
47         @Test
48         public void test1() {
49
50
51                 rh.reflect( "org.onap.dmaap.dbcapi.model.MirrorMaker", "get", null );   
52         
53         }
54         @Test
55         public void test2() {
56
57                 String v = "Validate";
58                 rh.reflect( "org.onap.dmaap.dbcapi.model.MirrorMaker", "set", v );
59         }
60
61         @Test
62         public void test3() {
63                 String f = "org.onap.interestingTopic";
64                 String c1 =  "cluster1.onap.org";
65                 String c2 =  "cluster2.onap.org";
66                 MirrorMaker t = new MirrorMaker( c1, c2 );
67                 String m = t.getMmName();
68
69                 MirrorMaker.genKey( c1, c2 );
70
71                 assertTrue( c1.equals( t.getSourceCluster() ));
72                 assertTrue( c2.equals( t.getTargetCluster() ));
73         }
74
75
76         @Test
77         public void test4() {
78                 String f = "org.onap.interestingTopic";
79                 String c1 =  "cluster1.onap.org";
80                 String c2 =  "cluster2.onap.org";
81                 MirrorMaker t = new MirrorMaker( c1, c2 );
82                 String m = t.getMmName();
83
84                 t.addVector( f, c1, c2 );
85                 ArrayList<String> topics = new ArrayList<String>();
86                 topics.add( f );
87                 t.setTopics( topics );
88                 t.addTopic( "org.onap.topic2" );
89
90                 int i = t.getTopicCount();
91
92                 String s = t.toJSON();
93
94                 s = t.updateWhiteList();
95
96                 s = t.createMirrorMaker();
97
98                 t.delVector( f, c1, c2 );
99
100         }
101
102 }