Commit 68adec60 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade nueva función de procesamiento base 

De esta manera se puede procesar eventos a partir del stream principal
en la implementación sin tener un objetivo específico (dependerá de la
implementación)
parent 5babcafc

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

+9 −0
Original line number Diff line number Diff line
@@ -59,6 +59,9 @@ public abstract class EventSourcingStreams extends BaseStreams { 
		// PostUpdate

		processPostUpdateStream(events);



		// extra process

		processExtraStreams(events);



		return new KafkaStreams(builder.build(),

				StreamUtils.baseStreamsConfig(bootstrapServers, stateStoreDir, serviceId, schemaRegistry));

	}
@@ -245,4 +248,10 @@ public abstract class EventSourcingStreams extends BaseStreams { 
	@Override

	protected void postProcessStreams() {

	}



	/*

	 * Función para procesar eventos a partir del stream principal y que dependerá

	 * del servicio que lo implemente

	 */

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

}