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

Obtiene items para enriquecer de topic snapshot

parent 43fe88fe

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

+1 −1
Original line number Diff line number Diff line
@@ -58,7 +58,7 @@ public class VesselEventStreams extends EventSourcingStreams { 
	public VesselEventStreams(StreamConfig config, String vesselTypeTopic, String vesselsAggByVesselTypeTopic,

			String vesselTypeUpdatedTopic, String vesselTrackingAggByVesselTopic, AlertService alertService) {

		super(config, alertService);

		this.vesselTypeTopic = vesselTypeTopic;

		this.vesselTypeTopic = vesselTypeTopic + snapshotTopicSuffix;

		this.vesselsAggByVesselTypeTopic = vesselsAggByVesselTypeTopic;

		this.vesselTypeUpdatedTopic = vesselTypeUpdatedTopic;

		this.vesselTrackingAggByVesselTopic = vesselTrackingAggByVesselTopic;

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

+1 −1
Original line number Diff line number Diff line
@@ -50,7 +50,7 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 
	public VesselTrackingEventStreams(StreamConfig config, String vesselTopic, String vesselTrackingAggByVesselTopic,

			String vesselUpdatedTopic, AlertService alertService) {

		super(config, alertService);

		this.vesselTopic = vesselTopic;

		this.vesselTopic = vesselTopic + snapshotTopicSuffix;

		this.vesselTrackingAggByVesselTopic = vesselTrackingAggByVesselTopic;

		this.vesselUpdatedTopic = vesselUpdatedTopic;

		this.hashMapSerde = new HashMapSerde<String, AggregationVesselInVesselTrackingPostUpdateEvent>(schemaRegistry);