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

Añade filtro para descartar eventos nulos

parent b9060efb

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

+1 −1
Original line number Diff line number Diff line
@@ -268,7 +268,7 @@ public class VesselEventStreams extends EventSourcingStreams { 
		// Join por id, mandando a kafka el evento de compensación

		partialUpdateEvent.join(successEventsTable, (partialUpdateConfirmEvent,

				lastSuccessEvent) -> getUpdatedEventFromPartialUpdate(partialUpdateConfirmEvent, lastSuccessEvent))

				.to(topic);

				.filter((k, v) -> (v != null)).to(topic);

	}



	/**