summaryrefslogtreecommitdiffstats
path: root/prh-dmaap-client/src/test/java
diff options
context:
space:
mode:
authorpwielebs <piotr.wielebski@nokia.com>2018-05-16 16:03:00 +0200
committerpwielebs <piotr.wielebski@nokia.com>2018-05-16 17:31:26 +0200
commit038424df570080a72baf9f82309b353922630457 (patch)
tree000d9abd0fd02aaac7b45a43dcb9327a8133f575 /prh-dmaap-client/src/test/java
parent7412a22e82ed782c2a783483b80186c2f2fa3065 (diff)
Test classes added to Dmaap Client
Change-Id: Idf88fb43463d33fcec756f83818943be849a86c5 Issue-ID: DCAEGEN2-451 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
Diffstat (limited to 'prh-dmaap-client/src/test/java')
-rw-r--r--prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/service/config/DmaapConsumerConfigurationTest.java74
-rw-r--r--prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/service/config/DmaapPublisherConfigurationTest.java63
2 files changed, 137 insertions, 0 deletions
diff --git a/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/service/config/DmaapConsumerConfigurationTest.java b/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/service/config/DmaapConsumerConfigurationTest.java
new file mode 100644
index 00000000..2c076cef
--- /dev/null
+++ b/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/service/config/DmaapConsumerConfigurationTest.java
@@ -0,0 +1,74 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * PNF-REGISTRATION-HANDLER
+ * ================================================================================
+ * Copyright (C) 2018 NOKIA Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.dcaegen2.services.service.config;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.onap.dcaegen2.services.config.DmaapConsumerConfiguration;
+import org.onap.dcaegen2.services.config.ImmutableDmaapConsumerConfiguration;
+
+public class DmaapConsumerConfigurationTest {
+ // Given
+ private DmaapConsumerConfiguration configuration;
+ private String consumerId = "1";
+ private String dmaapHostName = "localhost";
+ private Integer dmaapPortNumber = 2222;
+ private String dmaapTopicName = "temp";
+ private String dmaapProtocol = "http";
+ private String dmaapUserName = "admin";
+ private String dmaapUserPassword = "admin";
+ private String dmaapContentType = "application/json";
+ private String consumerGroup = "other";
+ private Integer timeoutMs = 1000;
+ private Integer messageLimit = 1000;
+
+
+ @Test
+ public void builder_shouldBuildConfigurationObject() {
+ // When
+ configuration = new ImmutableDmaapConsumerConfiguration.Builder()
+ .consumerId(consumerId)
+ .dmaapHostName(dmaapHostName)
+ .dmaapPortNumber(dmaapPortNumber)
+ .dmaapTopicName(dmaapTopicName)
+ .dmaapProtocol(dmaapProtocol)
+ .dmaapUserName(dmaapUserName)
+ .dmaapUserPassword(dmaapUserPassword)
+ .dmaapContentType(dmaapContentType)
+ .consumerGroup(consumerGroup)
+ .timeoutMS(timeoutMs)
+ .messageLimit(messageLimit)
+ .build();
+
+ // Then
+ Assertions.assertNotNull(configuration);
+ Assertions.assertEquals(consumerId, configuration.consumerId());
+ Assertions.assertEquals(dmaapHostName, configuration.dmaapHostName());
+ Assertions.assertEquals(dmaapPortNumber, configuration.dmaapPortNumber());
+ Assertions.assertEquals(dmaapTopicName, configuration.dmaapTopicName());
+ Assertions.assertEquals(dmaapProtocol, configuration.dmaapProtocol());
+ Assertions.assertEquals(dmaapUserName, configuration.dmaapUserName());
+ Assertions.assertEquals(dmaapUserPassword, configuration.dmaapUserPassword());
+ Assertions.assertEquals(consumerGroup, configuration.consumerGroup());
+ Assertions.assertEquals(timeoutMs, configuration.timeoutMS());
+ Assertions.assertEquals(messageLimit, configuration.messageLimit());
+ }
+}
diff --git a/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/service/config/DmaapPublisherConfigurationTest.java b/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/service/config/DmaapPublisherConfigurationTest.java
new file mode 100644
index 00000000..7796da5c
--- /dev/null
+++ b/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/service/config/DmaapPublisherConfigurationTest.java
@@ -0,0 +1,63 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * PNF-REGISTRATION-HANDLER
+ * ================================================================================
+ * Copyright (C) 2018 NOKIA Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.dcaegen2.services.service.config;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.onap.dcaegen2.services.config.DmaapPublisherConfiguration;
+import org.onap.dcaegen2.services.config.ImmutableDmaapPublisherConfiguration;
+
+public class DmaapPublisherConfigurationTest {
+
+ // Given
+ private DmaapPublisherConfiguration configuration;
+ private String dmaapHostName = "localhost";
+ private Integer dmaapPortNumber = 2222;
+ private String dmaapTopicName = "temp";
+ private String dmaapProtocol = "http";
+ private String dmaapUserName = "admin";
+ private String dmaapUserPassword = "admin";
+ private String dmaapContentType = "application/json";
+
+
+ @Test
+ public void builder_shouldBuildConfigurationObject() {
+ // When
+ configuration = new ImmutableDmaapPublisherConfiguration.Builder()
+ .dmaapHostName(dmaapHostName)
+ .dmaapPortNumber(dmaapPortNumber)
+ .dmaapTopicName(dmaapTopicName)
+ .dmaapProtocol(dmaapProtocol)
+ .dmaapUserName(dmaapUserName)
+ .dmaapUserPassword(dmaapUserPassword)
+ .dmaapContentType(dmaapContentType)
+ .build();
+
+ // Then
+ Assertions.assertNotNull(configuration);
+ Assertions.assertEquals(dmaapHostName, configuration.dmaapHostName());
+ Assertions.assertEquals(dmaapPortNumber, configuration.dmaapPortNumber());
+ Assertions.assertEquals(dmaapTopicName, configuration.dmaapTopicName());
+ Assertions.assertEquals(dmaapProtocol, configuration.dmaapProtocol());
+ Assertions.assertEquals(dmaapUserName, configuration.dmaapUserName());
+ Assertions.assertEquals(dmaapUserPassword, configuration.dmaapUserPassword());
+ }
+}