[DMAAP-MR] Get topics from kafka option

[dmaap/messagerouter/messageservice.git] / src / test / java / org / onap / dmaap / mr / cambria / beans / DMaaPKafkaMetaBrokerTest.java

diff --git a/src/test/java/org/onap/dmaap/mr/cambria/beans/DMaaPKafkaMetaBrokerTest.java b/src/test/java/org/onap/dmaap/mr/cambria/beans/DMaaPKafkaMetaBrokerTest.java
index d59c839..1c717ca 100644 (file)
--- a/src/test/java/org/onap/dmaap/mr/cambria/beans/DMaaPKafkaMetaBrokerTest.java
+++ b/src/test/java/org/onap/dmaap/mr/cambria/beans/DMaaPKafkaMetaBrokerTest.java
@@ -24,6 +24,8 @@ import static org.junit.Assert.assertTrue;
 import com.att.nsa.configs.ConfigDb;
 import com.att.nsa.configs.ConfigDbException;
 import com.att.nsa.configs.ConfigPath;
+import java.util.Properties;
+import org.mockito.ArgumentMatchers;
 import org.I0Itec.zkclient.ZkClient;
 import org.apache.kafka.clients.admin.AdminClient;
 import org.junit.Before;
@@ -47,15 +49,13 @@ import org.powermock.modules.junit4.PowerMockRunner;
 @PrepareForTest({ AdminClient.class })
 public class DMaaPKafkaMetaBrokerTest {
 
-       @InjectMocks
+       @Mock
        private DMaaPKafkaMetaBroker dMaaPKafkaMetaBroker;
        @Mock
        private ZkClient fZk;
        @Mock
        private AdminClient fKafkaAdminClient;
        @Mock
-       private AdminClient client;
-       @Mock
        private ConfigDb configDb;
        @Mock
        ConfigPath fBaseTopicData;
@@ -68,18 +68,13 @@ public class DMaaPKafkaMetaBrokerTest {
        public void setUp() {
                MockitoAnnotations.initMocks(this);
                PowerMockito.mockStatic(AdminClient.class);
-               // PowerMockito.when(AdminClient.create (any(Properties.class)
-               // )).thenReturn(fKafkaAdminClient);
-
-               // PowerMockito.mockStatic(AdminUtils.class);
+               PowerMockito.when(AdminClient.create(ArgumentMatchers.any(Properties.class))).thenReturn(fKafkaAdminClient);
                PowerMockito.when(configDb.parse("/topics")).thenReturn(fBaseTopicData);
-
        }
 
        @Test
        public void testBrokercreate() {
                DMaaPKafkaMetaBroker broker = new DMaaPKafkaMetaBroker();
-
        }
 
        @Test
@@ -90,7 +85,6 @@ public class DMaaPKafkaMetaBrokerTest {
                } catch (Exception e) {
                        assertTrue(true);
                }
-
        }
 
        @Test
@@ -101,7 +95,6 @@ public class DMaaPKafkaMetaBrokerTest {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
-
        }
 
        @Test