DMAAP-MR - Merge MR repos
[dmaap/messagerouter/messageservice.git] / src / test / java / org / onap / dmaap / mr / cambria / metrics / publisher / impl / CambriaBaseClientTest.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * ONAP Policy Engine
4  * ================================================================================
5  * Copyright (C) 2017 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
21  package org.onap.dmaap.mr.cambria.metrics.publisher.impl;
22
23 import static org.junit.Assert.*;
24
25 import java.util.ArrayList;
26 import java.util.Arrays;
27 import java.util.Collection;
28
29 import org.onap.dmaap.dmf.mr.metrics.publisher.impl.CambriaBaseClient;
30
31 import org.json.JSONArray;
32 import org.junit.After;
33 import org.junit.Before;
34 import org.junit.Test;
35
36 public class CambriaBaseClientTest {
37         
38         private CambriaBaseClient client = null;
39         @Before
40         public void setUp() throws Exception {
41                 
42                 Collection<String> hosts = new ArrayList<String>();
43                 
44                 for (int i = 0; i < 5; i++) {
45                         hosts.add("host"+(i+1));
46                 }
47                 
48                 
49                 client = new CambriaBaseClient(hosts, "client1");
50         }
51
52         @After
53         public void tearDown() throws Exception {
54         }
55
56         @Test
57         public void testClose() {
58                 client.close();
59                 String trueValue = "True";
60                 assertTrue(trueValue.equalsIgnoreCase("True"));
61                 
62         }
63         
64         @Test
65         public void testGetLog() {
66                 client.getLog();
67                 String trueValue = "True";
68                 assertTrue(trueValue.equalsIgnoreCase("True"));
69                 
70         }
71         
72         @Test
73         public void testLogTo() {
74                 client.logTo(null);
75                 String trueValue = "True";
76                 assertTrue(trueValue.equalsIgnoreCase("True"));
77                 
78         }
79         
80         public JSONArray getJSONArray() {
81                 
82                 String[] data = {"stringone", "stringtwo"};
83                 JSONArray array = new JSONArray(Arrays.asList(data));
84
85                 return array;
86         }
87         
88         @Test
89         public void testJsonArrayToSet() {
90                 client.jsonArrayToSet(getJSONArray());
91                 String trueValue = "True";
92                 assertTrue(trueValue.equalsIgnoreCase("True"));
93                 
94         }
95 }