9aab22c291e4e61fcbe7954ce4fef3b265ad9a9e
[dcaegen2/services.git] /
1 /*******************************************************************************
2  *  ============LICENSE_START=======================================================
3  *  slice-analysis-ms
4  *  ================================================================================
5  *   Copyright (C) 2020 Wipro Limited.
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
22 package org.onap.slice.analysis.ms.dmaap;
23
24 import static org.mockito.Mockito.when;
25
26 import java.util.ArrayList;
27 import java.util.List;
28
29 import org.junit.Test;
30 import org.junit.runner.RunWith;
31 import org.mockito.InjectMocks;
32 import org.mockito.Mock;
33 import org.mockito.Mockito;
34 import org.springframework.boot.test.context.SpringBootTest;
35 import org.springframework.test.context.junit4.SpringRunner;
36
37 import com.att.nsa.cambria.client.CambriaConsumer;
38
39 @RunWith(SpringRunner.class)
40 @SpringBootTest(classes = NotificationConsumerTest.class)
41 public class NotificationConsumerTest {
42         
43         @Mock
44         CambriaConsumer cambriaConsumer;
45         
46         @Mock
47         NotificationCallback notificationCallback;
48
49         @InjectMocks
50         NotificationConsumer notificationConsumer;
51
52         @Test
53         public void testNotificationConsumer() {
54                 try {
55                         List<String> notifications = new ArrayList<>();
56                         notifications.add("notification1");
57                         when(cambriaConsumer.fetch()).thenReturn(notifications);
58                         Mockito.doNothing().when(notificationCallback).activateCallBack(Mockito.anyString());
59                         notificationConsumer.run();
60                         
61                 }catch(Exception e) {
62                         e.printStackTrace();
63                 }
64         }
65
66 }