Commit c2e3f6dd authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade fichero de configuración para KafkaEmbedded 

De este modo se centraliza la config para todos los tests
parent 25b7dc45

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

0 → 100644
+12 −0
Original line number Diff line number Diff line 
package es.redmic.test.vesselscommands.integration;



public class KafkaEmbeddedConfig {



	// number of brokers.

	public final static Integer NUM_BROKERS = 3;

	// partitions per topic.

	public final static Integer PARTITIONS_PER_TOPIC = 3;



	public final static String[] TOPICS_NAME = new String[] { "vessels-agg-by-vessel-type", "vessel-type", "vessel",

			"realtime.tracking.vessels" };

}

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

+3 −6
Original line number Diff line number Diff line
@@ -46,6 +46,7 @@ import org.springframework.util.concurrent.ListenableFuture; 


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

import es.redmic.brokerlib.listener.SendListener;

import es.redmic.test.vesselscommands.integration.KafkaEmbeddedConfig;

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

import es.redmic.testutils.documentation.DocumentationCommandBaseTest;

import es.redmic.vesselscommands.VesselsCommandsApplication;
@@ -71,13 +72,9 @@ import es.redmic.vesselslib.events.vessel.update.UpdateVesselEvent; 
@KafkaListener(topics = "${broker.topic.vessel}", groupId = "test")

public class CreateVesselFromRestTest extends DocumentationCommandBaseTest {



	// number of brokers.

	private final static Integer numBrokers = 3;

	// partitions per topic.

	private final static Integer partitionsPerTopic = 3;



	@ClassRule

	public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(numBrokers, true, partitionsPerTopic);

	public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(KafkaEmbeddedConfig.NUM_BROKERS, true,

			KafkaEmbeddedConfig.PARTITIONS_PER_TOPIC, KafkaEmbeddedConfig.TOPICS_NAME);



	private final Integer mmsi = 1111;

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

+3 −6
Original line number Diff line number Diff line
@@ -33,6 +33,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.KafkaEmbeddedConfig;

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

import es.redmic.testutils.kafka.KafkaBaseIntegrationTest;

import es.redmic.vesselscommands.VesselsCommandsApplication;
@@ -55,13 +56,9 @@ public class CreateVesselFromTrackingTest extends KafkaBaseIntegrationTest { 
	@Value("${broker.topic.vessel-type}")

	private String VESSEL_TYPE_TOPIC;



	// number of brokers.

	private final static Integer numBrokers = 3;

	// partitions per topic.

	private final static Integer partitionsPerTopic = 3;



	@ClassRule

	public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(numBrokers, true, partitionsPerTopic);

	public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(KafkaEmbeddedConfig.NUM_BROKERS, true,

			KafkaEmbeddedConfig.PARTITIONS_PER_TOPIC, KafkaEmbeddedConfig.TOPICS_NAME);



	@Autowired

	private KafkaTemplate<String, AISTrackingDTO> kafkaTemplate;

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

+3 −6
Original line number Diff line number Diff line
@@ -24,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.test.vesselscommands.integration.KafkaEmbeddedConfig;

import es.redmic.testutils.kafka.KafkaBaseIntegrationTest;

import es.redmic.vesselscommands.VesselsCommandsApplication;

import es.redmic.vesselscommands.handler.VesselCommandHandler;
@@ -40,13 +41,9 @@ public class GetVesselStateFromStoreTest extends KafkaBaseIntegrationTest { 


	protected static Logger logger = LogManager.getLogger();



	// number of brokers.

	private final static Integer numBrokers = 3;

	// partitions per topic.

	private final static Integer partitionsPerTopic = 3;



	@ClassRule

	public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(numBrokers, true, partitionsPerTopic);

	public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(KafkaEmbeddedConfig.NUM_BROKERS, true,

			KafkaEmbeddedConfig.PARTITIONS_PER_TOPIC, KafkaEmbeddedConfig.TOPICS_NAME);



	// @formatter:off

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

+3 −6
Original line number Diff line number Diff line
@@ -37,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.test.vesselscommands.integration.KafkaEmbeddedConfig;

import es.redmic.testutils.kafka.KafkaBaseIntegrationTest;

import es.redmic.vesselscommands.VesselsCommandsApplication;

import es.redmic.vesselscommands.handler.VesselCommandHandler;
@@ -68,13 +69,9 @@ public class VesselCommandHandlerTest extends KafkaBaseIntegrationTest { 


	protected static Logger logger = LogManager.getLogger();



	// number of brokers.

	private final static Integer numBrokers = 3;

	// partitions per topic.

	private final static Integer partitionsPerTopic = 3;



	@ClassRule

	public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(numBrokers, true, partitionsPerTopic);

	public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(KafkaEmbeddedConfig.NUM_BROKERS, true,

			KafkaEmbeddedConfig.PARTITIONS_PER_TOPIC, KafkaEmbeddedConfig.TOPICS_NAME);



	private static final Integer mmsi = 1234;