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

Descarta eventos que por error se reciben a null 

Si se envía ese evento a kafka se puede obtener resultados no deseados,
por ello, ante la posibilidad de que un join devuelva null, se filtran
esos casos
parent 68adec60

src/main/java/es/redmic/commandslib/streaming/streams/EventSourcingStreams.java

+2 −2
Original line number Diff line number Diff line
@@ -100,7 +100,7 @@ public abstract class EventSourcingStreams extends BaseStreams { 
		// Join por id, mandando a kafka el evento de éxito

		createConfirmedEvents.join(createRequestEvents,

				(confirmedEvent, requestEvent) -> getCreatedEvent(confirmedEvent, requestEvent),

				JoinWindows.of(windowsTime)).to(topic);

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

	}



	/*
@@ -137,7 +137,7 @@ public abstract class EventSourcingStreams extends BaseStreams { 
		// Join por id, mandando a kafka el evento de éxito

		updateConfirmedEvents.join(updateRequestEvents,

				(confirmedEvent, requestEvent) -> getUpdatedEvent(confirmedEvent, requestEvent),

				JoinWindows.of(windowsTime)).to(topic);

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



		processPartialUpdatedStream(events, updateConfirmedEvents);

	}