Commit 84156cd6 authored by Noel Alonso's avatar Noel Alonso
Browse files

Hace uso de stream snapshot para añadir tracks

parent 0087f9dc

vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselTrackingEventStreams.java

+2 −3
Original line number Diff line number Diff line
@@ -38,7 +38,6 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 
		super(config, alertService);

		this.vesselTopic = vesselTopic + snapshotTopicSuffix;

		this.realtimeTrackingVesselsTopic = realtimeTrackingVesselsTopic;

		logger.info("Arrancado servicio de streaming para event sourcing de Vessel tracking con Id: " + this.serviceId);

		init();

	}
@@ -255,9 +254,9 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 
	}



	@Override

	protected void processExtraStreams(KStream<String, Event> events) {

	protected void processExtraStreams(KStream<String, Event> events, KStream<String, Event> snapshotEvents) {



		createTrackingFromRealtimeTrackingVessel(realtimeTracking, events);

		createTrackingFromRealtimeTrackingVessel(realtimeTracking, snapshotEvents);

	}



	private void createTrackingFromRealtimeTrackingVessel(KStream<String, VesselTrackingDTO> realTimeTracking,

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

+1 −1
Original line number Diff line number Diff line
@@ -81,7 +81,7 @@ public class CreateVesselTrackingFromAISTest extends KafkaBaseIntegrationTest { 


		kafkaTemplate.send(REALTIME_TRACKING_VESSELS_TOPIC, source.getId(), source);



		Thread.sleep(10000);

		Thread.sleep(1000);



		kafkaTemplate.send(REALTIME_TRACKING_VESSELS_TOPIC, source.getId(), source);