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

Cambia join por leftJoin para permitir nulos 

En este caso puede que no haya snapshot (añadir un nuevo elemento) pero
se debe permitir hacer rollback
parent 77b1f9c5

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

+1 −1
Original line number Diff line number Diff line
@@ -269,7 +269,7 @@ public abstract class EventSourcingStreams extends BaseStreams { 
				.filter((id, event) -> (EventTypes.PREPARE_ROLLBACK.equals(event.getType())));



		// Join por id, mandando a kafka el evento específico

		prepareRollbackEvents.join(successEventsTable,

		prepareRollbackEvents.leftJoin(successEventsTable,

				(prepareRollbackEvent, lastSuccessEvent) -> getRollbackEvent(prepareRollbackEvent, lastSuccessEvent))

				.to(topic);

	}

src/main/java/es/redmic/commandslib/usersettings/streams/SettingsEventStreams.java

+1 −1
Original line number Diff line number Diff line
@@ -658,7 +658,7 @@ public class SettingsEventStreams extends BaseStreams { 
				.filter((id, event) -> (EventTypes.PREPARE_ROLLBACK.equals(event.getType())));



		// Join por id, mandando a kafka el evento específico

		prepareRollbackEvents.join(successEventsTable,

		prepareRollbackEvents.leftJoin(successEventsTable,

				(prepareRollbackEvent, lastSuccessEvent) -> getRollbackEvent(prepareRollbackEvent, lastSuccessEvent))

				.to(topic);

	}