Merge "DMAAP-MR - Merge MR repos"
[dmaap/messagerouter/messageservice.git] / src / test / java / org / onap / dmaap / mr / cambria / backends / kafka / KafkaPublisherTest.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.backends.kafka;
22
23 import static org.junit.Assert.assertTrue;
24
25 import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;
26 import org.junit.After;
27 import org.junit.Before;
28 import org.junit.Test;
29 import org.junit.runner.RunWith;
30 import org.mockito.MockitoAnnotations;
31 import org.onap.dmaap.dmf.mr.backends.kafka.KafkaPublisher;
32 import org.onap.dmaap.dmf.mr.utils.Utils;
33 import org.powermock.api.mockito.PowerMockito;
34 import org.powermock.core.classloader.annotations.PowerMockIgnore;
35 import org.powermock.core.classloader.annotations.PrepareForTest;
36 import org.powermock.modules.junit4.PowerMockRunner;
37
38 @PowerMockIgnore({"com.sun.org.apache.xerces.*", "javax.xml.*", "org.xml.*", "javax.management.*"})
39 @RunWith(PowerMockRunner.class)
40 @PrepareForTest({ Utils.class })
41 public class KafkaPublisherTest {
42
43         @Before
44         public void setUp() throws Exception {
45                 MockitoAnnotations.initMocks(this);
46                 PowerMockito.mockStatic(Utils.class);
47                 PowerMockito.when(Utils.isCadiEnabled()).thenReturn(true);
48
49         }
50
51         @After
52         public void tearDown() throws Exception {
53         }
54
55         @Test
56         public void testPublisherInit() {
57                 
58                 
59
60                 try {
61                         try {
62                                 KafkaPublisher kafkaPublisher = new KafkaPublisher(null);
63                         } catch (missingReqdSetting e) {
64                                 assertTrue(true);
65                         }
66                 } catch (LinkageError e) {
67                         assertTrue(true);
68                 }
69
70         }
71
72         
73
74 }