aboutsummaryrefslogtreecommitdiffstats
path: root/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/parameters/SyncParameterTests.java
diff options
context:
space:
mode:
Diffstat (limited to 'services/services-engine/src/test/java/org/onap/policy/apex/service/engine/parameters/SyncParameterTests.java')
-rw-r--r--services/services-engine/src/test/java/org/onap/policy/apex/service/engine/parameters/SyncParameterTests.java96
1 files changed, 51 insertions, 45 deletions
diff --git a/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/parameters/SyncParameterTests.java b/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/parameters/SyncParameterTests.java
index aaa98fd47..e9e989629 100644
--- a/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/parameters/SyncParameterTests.java
+++ b/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/parameters/SyncParameterTests.java
@@ -1,7 +1,7 @@
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2019-2020 Nordix Foundation.
+ * Modifications Copyright (C) 2019-2020, 2024 Nordix Foundation.
* Modifications Copyright (C) 2020 Bell Canada. All rights reserved.
* Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
* ================================================================================
@@ -24,11 +24,12 @@
package org.onap.policy.apex.service.engine.parameters;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertInstanceOf;
+import static org.junit.jupiter.api.Assertions.assertTrue;
import java.util.Arrays;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
import org.onap.policy.apex.service.engine.main.ApexCommandLineArguments;
import org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperDooperCarrierTechnologyParameters;
import org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperTokenDelimitedEventProtocolParameters;
@@ -44,9 +45,10 @@ import org.onap.policy.common.parameters.ParameterException;
*
* @author Liam Fallon (liam.fallon@ericsson.com)
*/
-public class SyncParameterTests {
+class SyncParameterTests {
+
@Test
- public void testSyncBadNoSyncWithPeer() throws ParameterException {
+ void testSyncBadNoSyncWithPeer() {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsNoSyncWithPeer.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -58,7 +60,7 @@ public class SyncParameterTests {
}
@Test
- public void testSyncBadNotSyncWithPeer() throws ParameterException {
+ void testSyncBadNotSyncWithPeer() {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsNotSyncWithPeer.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -70,7 +72,7 @@ public class SyncParameterTests {
}
@Test
- public void testSyncBadSyncBadPeers() throws ParameterException {
+ void testSyncBadSyncBadPeers() {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsBadPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -85,7 +87,7 @@ public class SyncParameterTests {
}
@Test
- public void testSyncBadSyncInvalidTimeout() throws ParameterException {
+ void testSyncBadSyncInvalidTimeout() {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsInvalidTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -103,7 +105,7 @@ public class SyncParameterTests {
}
@Test
- public void testSyncBadSyncBadTimeout() throws ParameterException {
+ void testSyncBadSyncBadTimeout() {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsBadTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -115,7 +117,7 @@ public class SyncParameterTests {
}
@Test
- public void testSyncBadSyncUnpairedTimeout() throws ParameterException {
+ void testSyncBadSyncUnpairedTimeout() {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsUnpairedTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -133,17 +135,17 @@ public class SyncParameterTests {
}
@Test
- public void testSyncGoodSyncGoodTimeoutProducer() throws ParameterException {
+ void testSyncGoodSyncGoodTimeoutProducer() throws ParameterException {
verifySyncGoodSyncGoodTimeout("src/test/resources/parameters/syncGoodParamsProducerTimeout.json");
}
@Test
- public void testSyncGoodSyncGoodTimeoutConsumer() throws ParameterException {
+ void testSyncGoodSyncGoodTimeoutConsumer() throws ParameterException {
verifySyncGoodSyncGoodTimeout("src/test/resources/parameters/syncGoodParamsConsumerTimeout.json");
}
@Test
- public void testSyncGoodSyncGoodTimeoutBoth() throws ParameterException {
+ void testSyncGoodSyncGoodTimeoutBoth() throws ParameterException {
verifySyncGoodSyncGoodTimeout("src/test/resources/parameters/syncGoodParamsBothTimeout.json");
}
@@ -152,18 +154,18 @@ public class SyncParameterTests {
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
final ApexParameters parameters = new ApexParameterHandler().getParameters(arguments);
- assertEquals(fileName, 12345, parameters.getEventInputParameters().get("SyncConsumer0")
- .getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
- assertEquals(fileName, 1, parameters.getEventInputParameters().get("SyncConsumer1")
- .getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
- assertEquals(fileName, 12345, parameters.getEventOutputParameters().get("SyncProducer0")
- .getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
- assertEquals(fileName, 1, parameters.getEventOutputParameters().get("SyncProducer1")
- .getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
+ assertEquals(12345, parameters.getEventInputParameters().get("SyncConsumer0")
+ .getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
+ assertEquals(1, parameters.getEventInputParameters().get("SyncConsumer1")
+ .getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
+ assertEquals(12345, parameters.getEventOutputParameters().get("SyncProducer0")
+ .getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
+ assertEquals(1, parameters.getEventOutputParameters().get("SyncProducer1")
+ .getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
}
@Test
- public void testSyncUnusedConsumerPeers() throws ParameterException {
+ void testSyncUnusedConsumerPeers() {
final String[] args = {"-p", "src/test/resources/parameters/syncUnusedConsumerPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -177,7 +179,7 @@ public class SyncParameterTests {
}
@Test
- public void testSyncMismatchedPeers() throws ParameterException {
+ void testSyncMismatchedPeers() {
final String[] args = {"-p", "src/test/resources/parameters/syncMismatchedPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -195,7 +197,7 @@ public class SyncParameterTests {
}
@Test
- public void testSyncUnusedProducerPeers() throws ParameterException {
+ void testSyncUnusedProducerPeers() {
final String[] args = {"-p", "src/test/resources/parameters/syncUnusedProducerPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -209,7 +211,7 @@ public class SyncParameterTests {
}
@Test
- public void testSyncMismatchedTimeout() throws ParameterException {
+ void testSyncMismatchedTimeout() {
final String[] args = {"-p", "src/test/resources/parameters/syncMismatchedTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -223,7 +225,7 @@ public class SyncParameterTests {
}
@Test
- public void testSyncGoodParametersTest() throws ParameterException {
+ void testSyncGoodParametersTest() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncGoodParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
@@ -236,21 +238,21 @@ public class SyncParameterTests {
assertEquals(65522, parameters.getEngineServiceParameters().getDeploymentPort());
final CarrierTechnologyParameters prodCT0 =
- parameters.getEventOutputParameters().get("SyncProducer0").getCarrierTechnologyParameters();
+ parameters.getEventOutputParameters().get("SyncProducer0").getCarrierTechnologyParameters();
final EventProtocolParameters prodEP0 =
- parameters.getEventOutputParameters().get("SyncProducer0").getEventProtocolParameters();
+ parameters.getEventOutputParameters().get("SyncProducer0").getEventProtocolParameters();
final CarrierTechnologyParameters consCT0 =
- parameters.getEventInputParameters().get("SyncConsumer0").getCarrierTechnologyParameters();
+ parameters.getEventInputParameters().get("SyncConsumer0").getCarrierTechnologyParameters();
final EventProtocolParameters consEP0 =
- parameters.getEventInputParameters().get("SyncConsumer0").getEventProtocolParameters();
+ parameters.getEventInputParameters().get("SyncConsumer0").getEventProtocolParameters();
final CarrierTechnologyParameters prodCT1 =
- parameters.getEventOutputParameters().get("SyncProducer1").getCarrierTechnologyParameters();
+ parameters.getEventOutputParameters().get("SyncProducer1").getCarrierTechnologyParameters();
final EventProtocolParameters prodEP1 =
- parameters.getEventOutputParameters().get("SyncProducer1").getEventProtocolParameters();
+ parameters.getEventOutputParameters().get("SyncProducer1").getEventProtocolParameters();
final CarrierTechnologyParameters consCT1 =
- parameters.getEventInputParameters().get("SyncConsumer1").getCarrierTechnologyParameters();
+ parameters.getEventInputParameters().get("SyncConsumer1").getCarrierTechnologyParameters();
final EventProtocolParameters consEP1 =
- parameters.getEventInputParameters().get("SyncConsumer1").getEventProtocolParameters();
+ parameters.getEventInputParameters().get("SyncConsumer1").getEventProtocolParameters();
assertEquals("FILE", prodCT0.getLabel());
assertEquals("JSON", prodEP0.getLabel());
@@ -261,11 +263,18 @@ public class SyncParameterTests {
assertEquals("SUPER_DOOPER", consCT1.getLabel());
assertEquals("SUPER_TOK_DEL", consEP1.getLabel());
- assertTrue(consCT1 instanceof SuperDooperCarrierTechnologyParameters);
- assertTrue(consEP1 instanceof SuperTokenDelimitedEventProtocolParameters);
+ assertInstanceOf(SuperDooperCarrierTechnologyParameters.class, consCT1);
+ assertInstanceOf(SuperTokenDelimitedEventProtocolParameters.class, consEP1);
final SuperDooperCarrierTechnologyParameters superDooperParameters =
- (SuperDooperCarrierTechnologyParameters) consCT1;
+ (SuperDooperCarrierTechnologyParameters) consCT1;
+ assertEqualsOnFields(superDooperParameters);
+
+ final String[] consumerTopics = {"apex-in"};
+ assertEquals(Arrays.asList(consumerTopics), superDooperParameters.getConsumerTopicList());
+ }
+
+ private static void assertEqualsOnFields(SuperDooperCarrierTechnologyParameters superDooperParameters) {
assertEquals("localhost:9092", superDooperParameters.getBootstrapServers());
assertEquals("all", superDooperParameters.getAcks());
assertEquals(0, superDooperParameters.getRetries());
@@ -279,15 +288,12 @@ public class SyncParameterTests {
assertEquals("apex-out", superDooperParameters.getProducerTopic());
assertEquals(100, superDooperParameters.getConsumerPollTime());
assertEquals("org.apache.superDooper.common.serialization.StringSerializer",
- superDooperParameters.getKeySerializer());
+ superDooperParameters.getKeySerializer());
assertEquals("org.apache.superDooper.common.serialization.StringSerializer",
- superDooperParameters.getValueSerializer());
+ superDooperParameters.getValueSerializer());
assertEquals("org.apache.superDooper.common.serialization.StringDeserializer",
- superDooperParameters.getKeyDeserializer());
+ superDooperParameters.getKeyDeserializer());
assertEquals("org.apache.superDooper.common.serialization.StringDeserializer",
- superDooperParameters.getValueDeserializer());
-
- final String[] consumerTopics = {"apex-in"};
- assertEquals(Arrays.asList(consumerTopics), superDooperParameters.getConsumerTopicList());
+ superDooperParameters.getValueDeserializer());
}
}