Commit 39f03949 authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia enriquecimiento de leftJoin a join 

Ya que este enriquecimiento es obligado
parent cf415688

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

+1 −1
Original line number Diff line number Diff line
@@ -91,7 +91,7 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 
				.selectKey((k, v) -> getVesselIdFromVesselTracking(v));



		enrichCreateEvents

				.leftJoin(vessel, (k, v) -> k,

				.join(vessel, (k, v) -> k,

						(enrichCreateEvent, vesselEvent) -> getEnrichCreateResultEvent(enrichCreateEvent, vesselEvent))

				.selectKey((k, v) -> v.getAggregateId()).to(topic);

	}