diff options
Diffstat (limited to 'components/kpi-computation-ms/src/test/java/org/onap/dcaegen2/kpi/dmaap/DmaapClientTest.java')
-rw-r--r-- | components/kpi-computation-ms/src/test/java/org/onap/dcaegen2/kpi/dmaap/DmaapClientTest.java | 33 |
1 files changed, 26 insertions, 7 deletions
diff --git a/components/kpi-computation-ms/src/test/java/org/onap/dcaegen2/kpi/dmaap/DmaapClientTest.java b/components/kpi-computation-ms/src/test/java/org/onap/dcaegen2/kpi/dmaap/DmaapClientTest.java index cc23bab8..f51bf241 100644 --- a/components/kpi-computation-ms/src/test/java/org/onap/dcaegen2/kpi/dmaap/DmaapClientTest.java +++ b/components/kpi-computation-ms/src/test/java/org/onap/dcaegen2/kpi/dmaap/DmaapClientTest.java @@ -21,8 +21,15 @@ package org.onap.dcaegen2.kpi.dmaap; +import static org.mockito.Mockito.when; + +import com.att.nsa.cambria.client.CambriaTopicManager; +import com.google.gson.Gson; +import com.google.gson.JsonObject; + import java.io.BufferedReader; import java.io.FileReader; +import java.io.IOException; import java.util.ArrayList; import java.util.HashSet; import java.util.List; @@ -32,20 +39,20 @@ import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.mockito.InjectMocks; +import org.mockito.Mock; import org.mockito.Mockito; import org.mockito.MockitoAnnotations; import org.onap.dcaegen2.kpi.models.Configuration; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; -//import com.att.nsa.cambria.client.CambriaTopicManager; -import com.google.gson.Gson; -import com.google.gson.JsonObject; - @RunWith(SpringRunner.class) @SpringBootTest(classes = DmaapClientTest.class) public class DmaapClientTest { + @Mock + private CambriaTopicManager topicManager; + @InjectMocks DmaapClient client; @@ -67,9 +74,18 @@ public class DmaapClientTest { configuration.setCid("cid"); configuration.setPollingInterval(30); configuration.setPollingTimeout(100); - client = Mockito.mock(DmaapClient.class); - client.initClient(); - Mockito.verify(client).initClient(); + + try { + when(topicManager.getTopics()).thenReturn(topics); + + client = Mockito.mock(DmaapClient.class); + client.initClient(); + Mockito.verify(client).initClient(); + // Mockito.verifycreateAndConfigureTopics(); + + } catch (IOException e) { + e.printStackTrace(); + } } @Test @@ -85,6 +101,9 @@ public class DmaapClientTest { configuration.updateConfigurationFromJsonObject(config); DmaapClient client = new DmaapClient(); client.initClient(); + // Mockito.verify(client).startClient(); + // Mockito.verifycreateAndConfigureTopics(); + } catch (Exception e) { e.printStackTrace(); } |