Añade pasos de enriquecimiento al procesamiento (a4d1c69e) · Commits · REDMIC Project / Server / Library / Commands lib

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

+22 −0

Original line number	Diff line number	Diff line
		@@ -28,9 +28,15 @@ public abstract class EventSourcingStreams extends BaseStreams {

		KStream<String, Event> events = builder.stream(topic);

		// Realiza el enriquecimiento del item antes de crear
		processEnrichCreateSteam(events);

		// Create Success
		processCreateSuccessStream(events);

		// Realiza el enriquecimiento del item antes de modificar
		processEnrichUpdateSteam(events);

		// Update Success
		processUpdateSuccessStream(events);

		@@ -53,6 +59,14 @@ public abstract class EventSourcingStreams extends BaseStreams {
		*/
		protected abstract void createExtraStreams();

		/*
		* Función que a partir de los eventos de tipo CreateEnrich y globalKTable de
		* las relaciones, enriquece el item antes de mandarlo a crear
		*
		*/

		protected abstract void processEnrichCreateSteam(KStream<String, Event> events);

		/*
		* Función que a partir de los eventos de crear y confirmación de la vista,
		* envía evento creado
		@@ -74,6 +88,14 @@ public abstract class EventSourcingStreams extends BaseStreams {
		JoinWindows.of(windowsTime)).to(topic);
		}

		/*
		* Función que a partir de los eventos de tipo UpdateEnrich y globalKTable de
		* las relaciones, enriquece el item antes de mandarlo a modificar
		*
		*/

		protected abstract void processEnrichUpdateSteam(KStream<String, Event> events);

		/*
		* Función que a partir del evento de confirmación de la vista y del evento
		* create (petición de creación), si todo es correcto, genera evento created