diff options
Diffstat (limited to 'plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka')
3 files changed, 16 insertions, 0 deletions
diff --git a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaConsumerTest.java b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaConsumerTest.java index 6c9cb6609..bbebbc3b8 100644 --- a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaConsumerTest.java +++ b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaConsumerTest.java @@ -23,6 +23,7 @@ package org.onap.policy.apex.plugins.event.carrier.kafka; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertNull; + import org.junit.Before; import org.junit.Test; import org.onap.policy.apex.service.engine.event.ApexEventException; @@ -39,6 +40,11 @@ public class ApexKafkaConsumerTest { ApexEventReceiver incomingEventReceiver = null; ApexEventProducer apexKafkaProducer = null; + /** + * Set up testing. + * + * @throws ApexEventException on test set up errors. + */ @Before public void setUp() throws ApexEventException { apexKafkaConsumer = new ApexKafkaConsumer(); diff --git a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaProducerTest.java b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaProducerTest.java index 3c70d0b60..7300474c7 100644 --- a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaProducerTest.java +++ b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaProducerTest.java @@ -23,6 +23,7 @@ package org.onap.policy.apex.plugins.event.carrier.kafka; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertNull; + import org.junit.Before; import org.junit.Test; import org.onap.policy.apex.service.engine.event.ApexEventException; @@ -39,6 +40,9 @@ public class ApexKafkaProducerTest { SynchronousEventCache synchronousEventCache = null; private static final long DEFAULT_SYNCHRONOUS_EVENT_TIMEOUT = 1000; + /** + * Set up testing. + */ @Before public void setUp() throws Exception { apexKafkaProducer = new ApexKafkaProducer(); diff --git a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/KafkaCarrierTechnologyParametersTest.java b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/KafkaCarrierTechnologyParametersTest.java index e26a64bb6..6eca1dcf0 100644 --- a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/KafkaCarrierTechnologyParametersTest.java +++ b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/KafkaCarrierTechnologyParametersTest.java @@ -21,6 +21,7 @@ package org.onap.policy.apex.plugins.event.carrier.kafka; import static org.junit.Assert.assertNotNull; + import java.util.Properties; import org.junit.Before; import org.junit.Test; @@ -33,6 +34,11 @@ public class KafkaCarrierTechnologyParametersTest { Properties kafkaConsumerProperties = null; GroupValidationResult result = null; + /** + * Set up testing. + * + * @throws Exception on setup errors + */ @Before public void setUp() throws Exception { kafkaCarrierTechnologyParameters = new KafkaCarrierTechnologyParameters(); |