Commit 0ca6853b authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade prefijo a la clave de los mensajes 

De este modo comparte prefijo con vessel y se puede realizar uniones sin reprocesar datos
parent db9cc230

src/main/java/es/redmic/ais/service/AISService.java

+4 −1
Original line number Diff line number Diff line
@@ -35,6 +35,9 @@ public class AISService { 


	protected static Logger logger = LogManager.getLogger();



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

	private String prefix;



	@Value("${aishub.service.url}")

	private String urlAIS;
@@ -131,7 +134,7 @@ public class AISService { 
		logger.info("Tracking vessel: " + dto.getMmsi());



		ListenableFuture<SendResult<String, AISTrackingDTO>> future = kafkaTemplate.send(TOPIC,

				dto.getMmsi().toString(), dto);

				prefix + dto.getMmsi().toString(), dto);



		future.addCallback(new SendListener());

	}

src/main/resources/application.properties

+3 −1
Original line number Diff line number Diff line
@@ -13,7 +13,7 @@ info.vessels-view.outputEncoding=@project.reporting.outputEncoding@ 


logging.level.root=warn

logging.level.org.springframework=warn

logging.level.es.redmic=warn

logging.level.es.redmic=info

logging.level.es.redmic.brokerlib=error



spring.mvc.locale-resolver=fixed
@@ -41,6 +41,8 @@ spring.kafka.properties.schema.registry.url=${spring.kafka.properties.schema.reg 
#topic del broker para enviar nuevos tracking de barcos

broker.topic.realtime.tracking.vessels=realtime.tracking.vessels



broker.topic.realtime.tracking.vessels.key.prefix=vessel-mmsi-



config.fixedDelay=${config.fixedDelay}

app.scheduling.enable=${app.scheduling.enable}