2 * ============LICENSE_START=======================================================
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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
21 package org.onap.dmaap.mr.cambria.backends.kafka;
23 import static org.junit.Assert.*;
25 import java.util.concurrent.ConcurrentHashMap;
27 import org.apache.curator.framework.CuratorFramework;
28 import org.junit.After;
29 import org.junit.Before;
30 import org.junit.Test;
31 import org.junit.runner.RunWith;
32 import org.mockito.Mock;
33 import org.mockito.MockitoAnnotations;
34 import org.powermock.api.mockito.PowerMockito;
35 import org.powermock.core.classloader.annotations.PowerMockIgnore;
36 import org.powermock.modules.junit4.PowerMockRunner;
37 import org.powermock.core.classloader.annotations.PrepareForTest;
39 import com.att.ajsc.filemonitor.AJSCPropertiesMap;
41 import org.onap.dmaap.dmf.mr.backends.MetricsSet;
42 import org.onap.dmaap.dmf.mr.backends.kafka.Kafka011Consumer;
43 import org.onap.dmaap.dmf.mr.backends.kafka.KafkaConsumerCache;
44 import org.onap.dmaap.dmf.mr.backends.kafka.KafkaConsumerCache.KafkaConsumerCacheException;
45 import org.onap.dmaap.dmf.mr.constants.CambriaConstants;
46 import org.onap.dmaap.dmf.mr.security.DMaaPAuthenticatorImpl;
48 @PowerMockIgnore({"com.sun.org.apache.xerces.*", "javax.xml.*", "org.xml.*", "javax.management.*"})
49 @RunWith(PowerMockRunner.class)
50 @PrepareForTest({ AJSCPropertiesMap.class })
51 public class KafkaConsumerCacheTest {
52 private KafkaConsumerCache kafkaConsumerCache =null;
54 private ConcurrentHashMap<String, Kafka011Consumer> fConsumers;
56 private MetricsSet fMetrics;
59 public void setUp() throws Exception {
60 MockitoAnnotations.initMocks(this);
65 public void tearDown() throws Exception {
70 public void testSweep() {
71 kafkaConsumerCache = new KafkaConsumerCache();
72 PowerMockito.mockStatic(AJSCPropertiesMap.class);
73 PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "kSetting_TouchEveryMs")).thenReturn("100");
74 kafkaConsumerCache.sweep();
81 public void testStartCache() {
84 * KafkaConsumerCache kafka = null;
86 * try { kafka = new KafkaConsumerCache("123", null);
88 * } catch (NoClassDefFoundError e) { try { kafka.startCache("DMAAP",
89 * null); } catch (NullPointerException e1) { // TODO Auto-generated
90 * catch block assertTrue(true); } catch (KafkaConsumerCacheException
91 * e1) { // TODO Auto-generated catch block e1.printStackTrace(); } }
95 new CuratorFrameworkImpl();
97 KafkaConsumerCache kafka=null;
99 kafka = new KafkaConsumerCache();
100 kafka.setfApiId("1");
101 kafka.startCache("DMAAP", null);
102 } catch (NoClassDefFoundError e) {
104 } catch (KafkaConsumerCacheException e) {
105 // TODO Auto-generated catch block
112 public void testGetCuratorFramework() {
114 CuratorFramework curator = new CuratorFrameworkImpl();
115 new MetricsSetImpl();
118 } catch (NoClassDefFoundError e) {
120 KafkaConsumerCache.getCuratorFramework(curator);
126 * @Test public void testStopCache() {
128 * KafkaConsumerCache kafka = null; new CuratorFrameworkImpl(); new
129 * MetricsSetImpl(); try { kafka = new KafkaConsumerCache("123", null);
130 * kafka.stopCache(); } catch (NoClassDefFoundError e) {
138 public void testGetConsumerFor() {
140 KafkaConsumerCache kafka = null;
143 kafka = new KafkaConsumerCache();
144 kafka.getConsumerFor("testTopic", "CG1", "23");
145 } catch (NoClassDefFoundError e) {
147 } catch (KafkaConsumerCacheException e) {
148 // TODO Auto-generated catch block
155 public void testPutConsumerFor() {
157 Kafka011Consumer consumer = null;
158 KafkaConsumerCache kafka = null;
161 kafka = new KafkaConsumerCache();
163 } catch (NoClassDefFoundError e) {
165 kafka.putConsumerFor("testTopic", "CG1", "23", consumer);
166 } catch (NullPointerException e1) {
167 // TODO Auto-generated catch block
169 } catch (KafkaConsumerCacheException e1) {
170 // TODO Auto-generated catch block
171 e1.printStackTrace();
178 public void testGetConsumers() {
180 KafkaConsumerCache kafka = null;
183 kafka = new KafkaConsumerCache();
185 } catch (NoClassDefFoundError e) {
187 kafka.getConsumers();
188 } catch (NullPointerException e1) {
189 // TODO Auto-generated catch block
197 public void testDropAllConsumers() {
199 KafkaConsumerCache kafka = null;
201 kafka = new KafkaConsumerCache();
203 } catch (NoClassDefFoundError e) {
205 kafka.dropAllConsumers();
206 } catch (NullPointerException e1) {
207 // TODO Auto-generated catch block
215 public void testSignalOwnership() {
217 KafkaConsumerCache kafka = null;
220 kafka = new KafkaConsumerCache();
222 kafka.signalOwnership("testTopic", "CG1", "23");
223 } catch (KafkaConsumerCacheException e) {
226 } catch (NoClassDefFoundError e) {}
232 public void testDropConsumer() {
234 KafkaConsumerCache kafka = null;
237 kafka = new KafkaConsumerCache();
238 // kafka.dropConsumer("testTopic", "CG1", "23");
239 } catch (NoClassDefFoundError e) {
241 kafka.dropConsumer("testTopic", "CG1", "23");
242 } catch (NullPointerException e1) {
243 // TODO Auto-generated catch block