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

Cambia evento enviado a la factoría 

De este modo se construye el nuevo evento a partir del original
parent acd5a8ee

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

+4 −4
Original line number Diff line number Diff line
@@ -213,7 +213,7 @@ public class SettingsEventStreams extends BaseStreams { 


		SettingsDTO settings = ((SettingsEvent) requestEvent).getSettings();



		return SettingsEventFactory.getEvent(requestEvent, SettingsEventTypes.SELECTED, settings);

		return SettingsEventFactory.getEvent(confirmedEvent, SettingsEventTypes.SELECTED, settings);

	}



	// Deselect
@@ -283,7 +283,7 @@ public class SettingsEventStreams extends BaseStreams { 


		SettingsDTO settings = ((SettingsEvent) requestEvent).getSettings();



		return SettingsEventFactory.getEvent(requestEvent, SettingsEventTypes.DESELECTED, settings);

		return SettingsEventFactory.getEvent(confirmedEvent, SettingsEventTypes.DESELECTED, settings);

	}



	private void processDeselectFailedStream(KStream<String, Event> events, KTable<String, Event> snapshotKTable) {
@@ -381,7 +381,7 @@ public class SettingsEventStreams extends BaseStreams { 


		SettingsDTO settings = ((SettingsEvent) requestEvent).getSettings();



		return SettingsEventFactory.getEvent(requestEvent, SettingsEventTypes.SELECTION_CLEARED, settings);

		return SettingsEventFactory.getEvent(confirmedEvent, SettingsEventTypes.SELECTION_CLEARED, settings);

	}



	private void processClearSelectionFailedStream(KStream<String, Event> events,
@@ -508,7 +508,7 @@ public class SettingsEventStreams extends BaseStreams { 


		SettingsDTO settings = ((SettingsEvent) requestEvent).getSettings();



		return SettingsEventFactory.getEvent(requestEvent, SettingsEventTypes.SAVED, settings);

		return SettingsEventFactory.getEvent(confirmedEvent, SettingsEventTypes.SAVED, settings);

	}



	// Delete