Commit 16a7119d authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade servidor de schemaRegistry para tests

parent 686df2d8

pom.xml

+1 −0
Original line number Diff line number Diff line
@@ -31,6 +31,7 @@ 
		<redmic.test-utils.version>0.6.0</redmic.test-utils.version>

		<redmic.elasticsearch-lib.version>0.6.0</redmic.elasticsearch-lib.version>

		<redmic.view-lib.version>0.6.0</redmic.view-lib.version>

		<redmic.exceptions.version>0.6.0</redmic.exceptions.version>



		<!-- OTHERS -->

		<ma.glasnost.orika.core.version>1.5.2</ma.glasnost.orika.core.version>

vessels-commands/src/test/java/es/redmic/test/vesselscommands/integration/vessel/CreateVesselFromRestTest.java

+8 −0
Original line number Diff line number Diff line
@@ -18,6 +18,8 @@ import java.util.concurrent.BlockingQueue; 
import java.util.concurrent.LinkedBlockingDeque;

import java.util.concurrent.TimeUnit;



import javax.annotation.PostConstruct;



import org.junit.Before;

import org.junit.BeforeClass;

import org.junit.ClassRule;
@@ -105,6 +107,12 @@ public class CreateVesselFromRestTest extends DocumentationCommandBaseTest { 
	@Value("${broker.topic.vessel}")

	private String VESSEL_TOPIC;



	@PostConstruct

	public void CreateVesselFromRestTestPostConstruct() throws Exception {



		createSchemaRegistryRestApp(embeddedKafka.getZookeeperConnectionString(), embeddedKafka.getBrokersAsString());

	}



	@BeforeClass

	public static void setup() {

vessels-commands/src/test/java/es/redmic/test/vesselscommands/integration/vessel/CreateVesselFromTrackingTest.java

+9 −1
Original line number Diff line number Diff line
@@ -8,6 +8,8 @@ import java.util.concurrent.BlockingQueue; 
import java.util.concurrent.LinkedBlockingDeque;

import java.util.concurrent.TimeUnit;



import javax.annotation.PostConstruct;



import org.joda.time.DateTime;

import org.junit.Before;

import org.junit.BeforeClass;
@@ -32,6 +34,7 @@ import org.springframework.util.concurrent.ListenableFuture; 
import es.redmic.brokerlib.avro.geodata.tracking.vessels.AISTrackingDTO;

import es.redmic.brokerlib.listener.SendListener;

import es.redmic.test.vesselscommands.integration.vesseltype.VesselTypeDataUtil;

import es.redmic.testutils.kafka.KafkaBaseIntegrationTest;

import es.redmic.vesselscommands.VesselsCommandsApplication;

import es.redmic.vesselscommands.commands.VesselTypeCommandHandler;

import es.redmic.vesselscommands.statestore.VesselTypeStateStore;
@@ -43,7 +46,7 @@ import es.redmic.vesselslib.events.vessel.create.CreateVesselEvent; 
@SpringBootTest(classes = { VesselsCommandsApplication.class })

@ActiveProfiles("test")

@DirtiesContext

public class CreateVesselFromTrackingTest {

public class CreateVesselFromTrackingTest extends KafkaBaseIntegrationTest {



	@Value("${broker.topic.realtime.tracking.vessels}")

	String REALTIME_TRACKING_VESSELS_TOPIC;
@@ -69,6 +72,11 @@ public class CreateVesselFromTrackingTest { 
	@Autowired

	VesselTypeCommandHandler vesselTypeCommandHandler;



	@PostConstruct

	public void CreateVesselFromTrackingTestPostConstruct() throws Exception {

		createSchemaRegistryRestApp(embeddedKafka.getZookeeperConnectionString(), embeddedKafka.getBrokersAsString());

	}



	@BeforeClass

	public static void setup() {

vessels-commands/src/test/java/es/redmic/test/vesselscommands/integration/vessel/GetVesselStateFromStoreTest.java

+10 −1
Original line number Diff line number Diff line
@@ -3,6 +3,8 @@ package es.redmic.test.vesselscommands.integration.vessel; 
import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertNotNull;



import javax.annotation.PostConstruct;



import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.junit.ClassRule;
@@ -22,6 +24,7 @@ import org.springframework.util.concurrent.ListenableFuture; 


import es.redmic.brokerlib.avro.common.Event;

import es.redmic.brokerlib.listener.SendListener;

import es.redmic.testutils.kafka.KafkaBaseIntegrationTest;

import es.redmic.vesselscommands.VesselsCommandsApplication;

import es.redmic.vesselscommands.commands.VesselCommandHandler;

import es.redmic.vesselslib.dto.VesselDTO;
@@ -32,7 +35,7 @@ import es.redmic.vesselslib.events.vessel.update.UpdateVesselEvent; 
@SpringBootTest(classes = { VesselsCommandsApplication.class })

@ActiveProfiles("test")

@DirtiesContext

public class GetVesselStateFromStoreTest {

public class GetVesselStateFromStoreTest extends KafkaBaseIntegrationTest {



	protected static Logger logger = LogManager.getLogger();
@@ -63,6 +66,12 @@ public class GetVesselStateFromStoreTest { 
	@Autowired

	VesselCommandHandler vesselCommandHandler;



	@PostConstruct

	public void GetVesselStateFromStoreTestPostConstruct() throws Exception {



		createSchemaRegistryRestApp(embeddedKafka.getZookeeperConnectionString(), embeddedKafka.getBrokersAsString());

	}



	@Test

	public void createVessel_getVesselState_IfConfigIsCorrect() throws Exception {

vessels-commands/src/test/java/es/redmic/test/vesselscommands/integration/vessel/VesselCommandHandlerTest.java

+10 −1
Original line number Diff line number Diff line
@@ -9,6 +9,8 @@ import java.util.concurrent.CompletableFuture; 
import java.util.concurrent.LinkedBlockingDeque;

import java.util.concurrent.TimeUnit;



import javax.annotation.PostConstruct;



import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.junit.Before;
@@ -35,6 +37,7 @@ import es.redmic.brokerlib.listener.SendListener; 
import es.redmic.exception.data.DeleteItemException;

import es.redmic.exception.data.ItemAlreadyExistException;

import es.redmic.exception.data.ItemNotFoundException;

import es.redmic.testutils.kafka.KafkaBaseIntegrationTest;

import es.redmic.vesselscommands.VesselsCommandsApplication;

import es.redmic.vesselscommands.commands.VesselCommandHandler;

import es.redmic.vesselslib.dto.VesselDTO;
@@ -60,7 +63,7 @@ import es.redmic.vesselslib.events.vessel.update.VesselUpdatedEvent; 
@DirtiesContext

@KafkaListener(topics = "${broker.topic.vessel}", groupId = "${random.value}")

@TestPropertySource(properties = { "spring.kafka.consumer.group-id=VesselCommandHandlerTest" })

public class VesselCommandHandlerTest {

public class VesselCommandHandlerTest extends KafkaBaseIntegrationTest {



	protected static Logger logger = LogManager.getLogger();
@@ -85,6 +88,12 @@ public class VesselCommandHandlerTest { 
	@Autowired

	VesselCommandHandler vesselCommandHandler;



	@PostConstruct

	public void VesselCommandHandlerTestPostConstruct() throws Exception {



		createSchemaRegistryRestApp(embeddedKafka.getZookeeperConnectionString(), embeddedKafka.getBrokersAsString());

	}



	@Before

	public void setup() {