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;
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();
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;
SynchronousEventCache synchronousEventCache = null;
private static final long DEFAULT_SYNCHRONOUS_EVENT_TIMEOUT = 1000;
+ /**
+ * Set up testing.
+ */
@Before
public void setUp() throws Exception {
apexKafkaProducer = new ApexKafkaProducer();
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;
Properties kafkaConsumerProperties = null;
GroupValidationResult result = null;
+ /**
+ * Set up testing.
+ *
+ * @throws Exception on setup errors
+ */
@Before
public void setUp() throws Exception {
kafkaCarrierTechnologyParameters = new KafkaCarrierTechnologyParameters();