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

Hace uso de nueva función de command

parent e8c8d347

atlas-commands/src/main/java/es/redmic/atlascommands/handler/CategoryCommandHandler.java

+3 −26
Original line number Diff line number Diff line
@@ -20,8 +20,6 @@ package es.redmic.atlascommands.handler; 
 * #L%

 */



import java.util.concurrent.CompletableFuture;



import javax.annotation.PostConstruct;



import org.springframework.beans.factory.annotation.Autowired;
@@ -134,14 +132,7 @@ public class CategoryCommandHandler extends CommandHandler { 
		// Se aplica el evento

		agg.apply(event);



		// Crea la espera hasta que se responda con evento completado

		CompletableFuture<CategoryDTO> completableFuture = getCompletableFeature(event.getSessionId());



		// Emite evento para enviar a kafka

		publishToKafka(event, categoryTopic);



		// Obtiene el resultado cuando se resuelva la espera

		return getResult(event.getSessionId(), completableFuture);

		return sendEventAndWaitResult(event, categoryTopic);

	}



	public CategoryDTO update(String id, UpdateCategoryCommand cmd) {
@@ -158,14 +149,7 @@ public class CategoryCommandHandler extends CommandHandler { 
		// Si no existen excepciones, se aplica el comando

		agg.apply(event);



		// Crea la espera hasta que se responda con evento completado

		CompletableFuture<CategoryDTO> completableFuture = getCompletableFeature(event.getSessionId());



		// Emite evento para enviar a kafka

		publishToKafka(event, categoryTopic);



		// Obtiene el resultado cuando se resuelva la espera

		return getResult(event.getSessionId(), completableFuture);

		return sendEventAndWaitResult(event, categoryTopic);

	}



	public CategoryDTO update(String id, DeleteCategoryCommand cmd) {
@@ -183,14 +167,7 @@ public class CategoryCommandHandler extends CommandHandler { 
		// Si no existen excepciones, se aplica el comando

		agg.apply(event);



		// Crea la espera hasta que se responda con evento completado

		CompletableFuture<CategoryDTO> completableFuture = getCompletableFeature(event.getSessionId());



		// Emite evento para enviar a kafka

		publishToKafka(event, categoryTopic);



		// Obtiene el resultado cuando se resuelva la espera

		return getResult(event.getSessionId(), completableFuture);

		return sendEventAndWaitResult(event, categoryTopic);

	}



	@KafkaHandler

atlas-commands/src/main/java/es/redmic/atlascommands/handler/LayerCommandHandler.java

+4 −35
Original line number Diff line number Diff line
@@ -20,8 +20,6 @@ package es.redmic.atlascommands.handler; 
 * #L%

 */



import java.util.concurrent.CompletableFuture;



import javax.annotation.PostConstruct;



import org.apache.kafka.streams.KeyValue;
@@ -147,14 +145,7 @@ public class LayerCommandHandler extends CommandHandler { 
		// Se aplica el evento

		agg.apply(event);



		// Crea la espera hasta que se responda con evento completado

		CompletableFuture<LayerDTO> completableFuture = getCompletableFeature(event.getSessionId());



		// Emite evento para enviar a kafka

		publishToKafka(event, layerTopic);



		// Obtiene el resultado cuando se resuelva la espera

		return getResult(event.getSessionId(), completableFuture);

		return sendEventAndWaitResult(event, layerTopic);

	}



	public LayerDTO update(String id, UpdateLayerCommand cmd) {
@@ -171,20 +162,12 @@ public class LayerCommandHandler extends CommandHandler { 
		// Si no existen excepciones, se aplica el comando

		agg.apply(event);



		// Crea la espera hasta que se responda con evento completado

		CompletableFuture<LayerDTO> completableFuture = getCompletableFeature(event.getSessionId());



		// Emite evento para enviar a kafka

		publishToKafka(event, layerTopic);



		// Obtiene el resultado cuando se resuelva la espera

		return getResult(event.getSessionId(), completableFuture);

		return sendEventAndWaitResult(event, layerTopic);

	}



	public LayerDTO update(String id, DeleteLayerCommand cmd) {



		LayerAggregate agg = new LayerAggregate(layerStateStore, userService);

		agg.setAggregateId(id);



		// Se procesa el comando, obteniendo el evento generado

		CheckDeleteLayerEvent event = agg.process(cmd);
@@ -196,14 +179,7 @@ public class LayerCommandHandler extends CommandHandler { 
		// Si no existen excepciones, se aplica el comando

		agg.apply(event);



		// Crea la espera hasta que se responda con evento completado

		CompletableFuture<LayerDTO> completableFuture = getCompletableFeature(event.getSessionId());



		// Emite evento para enviar a kafka

		publishToKafka(event, layerTopic);



		// Obtiene el resultado cuando se resuelva la espera

		return getResult(event.getSessionId(), completableFuture);

		return sendEventAndWaitResult(event, layerTopic);

	}



	public LayerDTO refresh(RefreshLayerCommand cmd) {
@@ -220,14 +196,7 @@ public class LayerCommandHandler extends CommandHandler { 
		// Si no existen excepciones, se aplica el comando

		agg.apply(event);



		// Crea la espera hasta que se responda con evento completado

		CompletableFuture<LayerDTO> completableFuture = getCompletableFeature(event.getSessionId());



		// Emite evento para enviar a kafka

		publishToKafka(event, layerTopic);



		// Obtiene el resultado cuando se resuelva la espera

		return getResult(event.getSessionId(), completableFuture);

		return sendEventAndWaitResult(event, layerTopic);

	}



	@KafkaHandler

atlas-commands/src/main/java/es/redmic/atlascommands/handler/ThemeInspireCommandHandler.java

+3 −27
Original line number Diff line number Diff line
@@ -20,8 +20,6 @@ package es.redmic.atlascommands.handler; 
 * #L%

 */



import java.util.concurrent.CompletableFuture;



import javax.annotation.PostConstruct;



import org.springframework.beans.factory.annotation.Autowired;
@@ -137,14 +135,7 @@ public class ThemeInspireCommandHandler extends CommandHandler { 
		// Se aplica el evento

		agg.apply(event);



		// Crea la espera hasta que se responda con evento completado

		CompletableFuture<ThemeInspireDTO> completableFuture = getCompletableFeature(event.getSessionId());



		// Emite evento para enviar a kafka

		publishToKafka(event, themeInspireTopic);



		// Obtiene el resultado cuando se resuelva la espera

		return getResult(event.getSessionId(), completableFuture);

		return sendEventAndWaitResult(event, themeInspireTopic);

	}



	public ThemeInspireDTO update(String id, UpdateThemeInspireCommand cmd) {
@@ -161,20 +152,12 @@ public class ThemeInspireCommandHandler extends CommandHandler { 
		// Si no existen excepciones, se aplica el comando

		agg.apply(event);



		// Crea la espera hasta que se responda con evento completado

		CompletableFuture<ThemeInspireDTO> completableFuture = getCompletableFeature(event.getSessionId());



		// Emite evento para enviar a kafka

		publishToKafka(event, themeInspireTopic);



		// Obtiene el resultado cuando se resuelva la espera

		return getResult(event.getSessionId(), completableFuture);

		return sendEventAndWaitResult(event, themeInspireTopic);

	}



	public ThemeInspireDTO update(String id, DeleteThemeInspireCommand cmd) {



		ThemeInspireAggregate agg = new ThemeInspireAggregate(themeInspireStateStore, userService);

		agg.setAggregateId(id);



		// Se procesa el comando, obteniendo el evento generado

		CheckDeleteThemeInspireEvent event = agg.process(cmd);
@@ -186,14 +169,7 @@ public class ThemeInspireCommandHandler extends CommandHandler { 
		// Si no existen excepciones, se aplica el comando

		agg.apply(event);



		// Crea la espera hasta que se responda con evento completado

		CompletableFuture<ThemeInspireDTO> completableFuture = getCompletableFeature(event.getSessionId());



		// Emite evento para enviar a kafka

		publishToKafka(event, themeInspireTopic);



		// Obtiene el resultado cuando se resuelva la espera

		return getResult(event.getSessionId(), completableFuture);

		return sendEventAndWaitResult(event, themeInspireTopic);

	}



	@KafkaHandler