summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--prh-app-server/pom.xml5
-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
3 files changed, 142 insertions, 0 deletions
diff --git a/prh-app-server/pom.xml b/prh-app-server/pom.xml
index a8529d27..5706dc93 100644
--- a/prh-app-server/pom.xml
+++ b/prh-app-server/pom.xml
@@ -99,6 +99,11 @@
<directory>${project.build.directory}</directory>
<include>${project.fatJar.finalName}.jar</include>
</resource>
+ <resource>
+ <targetPath>/config</targetPath>
+ <directory>${project.build.directory}/config</directory>
+ <include>*</include>
+ </resource>
</resources>
<exposes>
<expose>8100</expose>
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());
+ }
+}