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

Añade envío de evento cuando se modifica un vessel 

De este modo se procesa directamente para hacer postupdate
parent a18c6734

vessels-commands/src/main/java/es/redmic/vesselscommands/handler/VesselCommandHandler.java

+7 −0
Original line number Diff line number Diff line
@@ -51,6 +51,9 @@ public class VesselCommandHandler extends CommandHandler { 
	@Value("${broker.topic.vessel}")

	private String vesselTopic;



	@Value("${broker.topic.vessel.updated}")

	private String vesselUpdatedTopic;



	@Value("${broker.topic.vessel.type.updated}")

	private String vesselTypeUpdatedTopic;
@@ -225,6 +228,10 @@ public class VesselCommandHandler extends CommandHandler { 


		logger.info("Vessel modificado " + event.getAggregateId());



		// Envía los editados satisfactoriamente para tenerlos en cuenta en el

		// postupdate

		publishToKafka(event, vesselUpdatedTopic);



		// El evento Modificado se envió desde el stream



		resolveCommand(event.getSessionId());