Loading vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselEventStreams.java +3 −1 Original line number Diff line number Diff line Loading @@ -456,7 +456,9 @@ public class VesselEventStreams extends EventSourcingStreams { VesselDTO currentVesselDTO = ((VesselEvent) vesselEvent).getVessel(); if (currentVesselDTO != null && !currentVesselDTO.equals(vesselDTO)) { if (VesselEventTypes.isSnapshot(vesselEvent.getType()) && currentVesselDTO != null && !currentVesselDTO.equals(vesselDTO)) { logger.info("Modificando barco vía stream " + currentVesselDTO.getId()); return getEnrichUpdateVesselEventFromRealtimeVessel(vesselDTO, vesselEvent); } return null; Loading Loading
vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselEventStreams.java +3 −1 Original line number Diff line number Diff line Loading @@ -456,7 +456,9 @@ public class VesselEventStreams extends EventSourcingStreams { VesselDTO currentVesselDTO = ((VesselEvent) vesselEvent).getVessel(); if (currentVesselDTO != null && !currentVesselDTO.equals(vesselDTO)) { if (VesselEventTypes.isSnapshot(vesselEvent.getType()) && currentVesselDTO != null && !currentVesselDTO.equals(vesselDTO)) { logger.info("Modificando barco vía stream " + currentVesselDTO.getId()); return getEnrichUpdateVesselEventFromRealtimeVessel(vesselDTO, vesselEvent); } return null; Loading