CodeCoverage improvement for dcaegen2-services-mapper

[dcaegen2/services/mapper.git] / UniversalVesAdapter / src / test / java / org / onap / universalvesadapter / configs / DmaapMrBaseConfigTest.java

diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/configs/DmaapMrBaseConfigTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/configs/DmaapMrBaseConfigTest.java
index 495722f..e0b72de 100644 (file)
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/configs/DmaapMrBaseConfigTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/configs/DmaapMrBaseConfigTest.java
@@ -1,6 +1,7 @@
 /*-\r
  * ============LICENSE_START=======================================================\r
  *  Copyright (C) 2019 Samsung. All rights reserved.\r
+ *  Copyright (C) 2022 Huawei. All rights reserved.\r
  * ================================================================================\r
  * Licensed under the Apache License, Version 2.0 (the "License");\r
  * you may not use this file except in compliance with the License.\r
@@ -22,11 +23,18 @@ package org.onap.universalvesadapter.configs;
 import static org.junit.Assert.assertEquals;\r
 import static org.junit.Assert.assertNotNull;\r
 import static org.junit.Assert.assertNull;\r
+import static org.junit.Assert.assertFalse;\r
+import static org.junit.Assert.assertTrue;\r
+import static org.junit.Assert.assertNotEquals;\r
 \r
 import org.junit.Before;\r
 import org.junit.Test;\r
 import org.mockito.Mockito;\r
 import org.onap.universalvesadapter.exception.DMaapException;\r
+import org.onap.universalvesadapter.utils.DmaapConfig;\r
+\r
+import java.io.IOException;\r
+\r
 \r
 public class DmaapMrBaseConfigTest {\r
     DMaaPMRBaseConfig dmaapMrBaseConfig = null;\r
@@ -75,4 +83,105 @@ public class DmaapMrBaseConfigTest {
         assertEquals(JSON_APPLICATION_TYPE,\r
                 DMaaPMRBaseConfig.normalizeValidateContentType("application/json"));\r
     }\r
+\r
+    @Test\r
+    public void testDMaaPMRSubscriberConfig() throws IOException {\r
+        DMaaPMRSubscriberConfig dMaaPMRSubscriberConfig = new DMaaPMRSubscriberConfig(new DMaaPMRSubscriberConfig\r
+                .Builder("test", new DmaapConfig()));\r
+        assertNotNull(dMaaPMRSubscriberConfig);\r
+        String timeout = dMaaPMRSubscriberConfig.getTimeoutMSParam();\r
+        assertNull(timeout);\r
+        dMaaPMRSubscriberConfig.setTimeoutMSParam("10");\r
+        timeout = dMaaPMRSubscriberConfig.getTimeoutMSParam();\r
+        assertNotNull(timeout);\r
+        String limitParam = dMaaPMRSubscriberConfig.getMessageLimitParam();\r
+        assertNull(limitParam);\r
+        dMaaPMRSubscriberConfig.setMessageLimitParam("test");\r
+        dMaaPMRSubscriberConfig.setUriPrefix("test");\r
+        String uriPrefix = dMaaPMRSubscriberConfig.getUriPrefix();\r
+        assertNotNull(uriPrefix);\r
+        String consumerId = dMaaPMRSubscriberConfig.getConsumerId();\r
+        assertNull(consumerId);\r
+        String consumerGroup = dMaaPMRSubscriberConfig.getConsumerGroup();\r
+        assertNull(consumerGroup);\r
+        int timeoutMS = dMaaPMRSubscriberConfig.getTimeoutMS();\r
+        assertEquals(0, timeoutMS);\r
+        int messageLimit = dMaaPMRSubscriberConfig.getMessageLimit();\r
+        assertEquals(0, messageLimit);\r
+        boolean result = dMaaPMRSubscriberConfig.equals(new Object());\r
+        assertFalse(result);\r
+        result = dMaaPMRSubscriberConfig.equals(new DMaaPMRSubscriberConfig(new DMaaPMRSubscriberConfig\r
+                .Builder("test", new DmaapConfig())));\r
+        assertTrue(result);\r
+        int res = dMaaPMRSubscriberConfig.hashCode();\r
+        assertNotEquals(0, res);\r
+    }\r
+\r
+    @Test\r
+    public void testDMaaPMRSubscriberConfigBuilder() throws IOException {\r
+        DMaaPMRSubscriberConfig.Builder builder = new DMaaPMRSubscriberConfig\r
+                .Builder("test", new DmaapConfig());\r
+        DMaaPMRSubscriberConfig.Builder builder1 = builder.setPortNumber(1234);\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setUserName("john");\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setUserPassword("sample");\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setProtocol("HTTPS");\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setContentType("application/json");\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setConsumerId("1234");\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setConsumerGroup("consumergroup");\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setTimeoutMS(10);\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setMessageLimit(10);\r
+        assertNotNull(builder1);\r
+        DMaaPMRSubscriberConfig dMaaPMRSubscriberConfig = builder.build();\r
+        assertNotNull(dMaaPMRSubscriberConfig);\r
+    }\r
+\r
+    @Test\r
+    public void testDMaaPMRPublisherConfig() throws IOException {\r
+        DMaaPMRPublisherConfig dMaaPMRPublisherConfig = new DMaaPMRPublisherConfig(new DMaaPMRPublisherConfig\r
+                .Builder("test", new DmaapConfig()));\r
+        assertNotNull(dMaaPMRPublisherConfig);\r
+        String uriPathPrefix = dMaaPMRPublisherConfig.getDmaapUriPathPrefix();\r
+        assertNull(uriPathPrefix);\r
+        int maxBatchSize = dMaaPMRPublisherConfig.getMaxBatchSize();\r
+        assertEquals(0, maxBatchSize);\r
+        int maxRecoveryQueueSize = dMaaPMRPublisherConfig.getMaxRecoveryQueueSize();\r
+        assertEquals(0, maxRecoveryQueueSize);\r
+        boolean result = dMaaPMRPublisherConfig.equals(new Object());\r
+        assertFalse(result);\r
+        result = dMaaPMRPublisherConfig.equals(new DMaaPMRPublisherConfig(new DMaaPMRPublisherConfig\r
+                .Builder("test", new DmaapConfig())));\r
+        assertTrue(result);\r
+        int res = dMaaPMRPublisherConfig.hashCode();\r
+        assertNotEquals(0, res);\r
+    }\r
+\r
+    @Test\r
+    public void testDMaaPMRPublisherConfigBuilder() throws IOException {\r
+        DMaaPMRPublisherConfig.Builder builder = new DMaaPMRPublisherConfig\r
+                .Builder("test", new DmaapConfig());\r
+        DMaaPMRPublisherConfig.Builder builder1 = builder.setPortNumber(1234);\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setUserName("john");\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setUserPassword("sample");\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setProtocol("HTTPS");\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setContentType("application/json");\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setMaxBatchSize(10);\r
+        assertNotNull(builder1);\r
+        builder1 = builder.setMaxRecoveryQueueSize(10);\r
+        assertNotNull(builder1);\r
+        DMaaPMRPublisherConfig dMaaPMRPublisherConfig = builder.build();\r
+        assertNotNull(dMaaPMRPublisherConfig);\r
+    }\r
 }\r