Commit 3f9fc3b9 authored by Noel Alonso's avatar Noel Alonso
Browse files

No envía item al crear la espera sino al resolver

parent 513e52d9

src/main/java/es/redmic/commandslib/usersettings/handler/SettingsCommandHandler.java

+10 −16
Original line number Original line Diff line number Diff line
@@ -155,8 +155,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		logger.debug("Aplicado evento: " + event.getType());

		logger.debug("Aplicado evento: " + event.getType());





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

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

		CompletableFuture<SettingsDTO> completableFuture = getCompletableFeature(event.getSessionId(),

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

				agg.getSettings());





		// Emite evento para enviar a kafka

		// Emite evento para enviar a kafka

		publishToKafka(event, settingsTopic);

		publishToKafka(event, settingsTopic);
@@ -192,8 +191,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		logger.debug("Aplicado evento: " + event.getType());

		logger.debug("Aplicado evento: " + event.getType());





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

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

		CompletableFuture<SettingsDTO> completableFuture = getCompletableFeature(event.getSessionId(),

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

				agg.getSettings());





		// Emite evento para enviar a kafka

		// Emite evento para enviar a kafka

		publishToKafka(event, settingsTopic);

		publishToKafka(event, settingsTopic);
@@ -226,8 +224,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		logger.debug("Aplicado evento: " + event.getType());

		logger.debug("Aplicado evento: " + event.getType());





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

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

		CompletableFuture<SettingsDTO> completableFuture = getCompletableFeature(event.getSessionId(),

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

				agg.getSettings());





		// Emite evento para enviar a kafka

		// Emite evento para enviar a kafka

		publishToKafka(event, settingsTopic);

		publishToKafka(event, settingsTopic);
@@ -260,8 +257,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		logger.debug("Aplicado evento: " + event.getType());

		logger.debug("Aplicado evento: " + event.getType());





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

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

		CompletableFuture<SettingsDTO> completableFuture = getCompletableFeature(event.getSessionId(),

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

				agg.getSettings());





		// Emite evento para enviar a kafka

		// Emite evento para enviar a kafka

		publishToKafka(event, settingsTopic);

		publishToKafka(event, settingsTopic);
@@ -294,8 +290,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		logger.debug("Aplicado evento: " + event.getType());

		logger.debug("Aplicado evento: " + event.getType());





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

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

		CompletableFuture<SettingsDTO> completableFuture = getCompletableFeature(event.getSessionId(),

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

				agg.getSettings());





		// Emite evento para enviar a kafka

		// Emite evento para enviar a kafka

		publishToKafka(event, settingsTopic);

		publishToKafka(event, settingsTopic);
@@ -325,8 +320,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		logger.debug("Aplicado evento: " + event.getType());

		logger.debug("Aplicado evento: " + event.getType());





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

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

		CompletableFuture<SettingsDTO> completableFuture = getCompletableFeature(event.getSessionId(),

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

				agg.getSettings());





		// Emite evento para enviar a kafka

		// Emite evento para enviar a kafka

		publishToKafka(event, settingsTopic);

		publishToKafka(event, settingsTopic);
@@ -344,7 +338,7 @@ public class SettingsCommandHandler extends CommandHandler { 




		// El evento selected se envía desde el stream

		// El evento selected se envía desde el stream





		resolveCommand(event.getSessionId());

		resolveCommand(event.getSessionId(), event.getSettings());

	}

	}





	@KafkaHandler

	@KafkaHandler
@@ -365,7 +359,7 @@ public class SettingsCommandHandler extends CommandHandler { 




		// El evento deselected se envía desde el stream

		// El evento deselected se envía desde el stream





		resolveCommand(event.getSessionId());

		resolveCommand(event.getSessionId(), event.getSettings());

	}

	}





	@KafkaHandler

	@KafkaHandler
@@ -386,7 +380,7 @@ public class SettingsCommandHandler extends CommandHandler { 




		// El evento selectionCleared se envía desde el stream

		// El evento selectionCleared se envía desde el stream





		resolveCommand(event.getSessionId());

		resolveCommand(event.getSessionId(), event.getSettings());

	}

	}





	@KafkaHandler

	@KafkaHandler
@@ -407,7 +401,7 @@ public class SettingsCommandHandler extends CommandHandler { 




		// El evento settingsSaved se envía desde el stream

		// El evento settingsSaved se envía desde el stream





		resolveCommand(event.getSessionId());

		resolveCommand(event.getSessionId(), event.getSettings());

	}

	}





	@KafkaHandler

	@KafkaHandler

src/test/java/es/redmic/commandslib/usersettings/common/SettingsCommandHandlerBase.java

+1 −3
Original line number Original line Diff line number Diff line
@@ -283,8 +283,6 @@ public class SettingsCommandHandlerBase extends KafkaBaseIntegrationTest { 
		Thread.sleep(1000);

		Thread.sleep(1000);





		PartialDeselectEvent partialDeselectEvent = SettingsDataUtil.getPartialDeselectEvent(code + "7");

		PartialDeselectEvent partialDeselectEvent = SettingsDataUtil.getPartialDeselectEvent(code + "7");

		partialDeselectEvent.getSelection().getSelection().clear();

		partialDeselectEvent.getSelection().getSelection().add("2");

		kafkaTemplate.send(settings_topic, partialDeselectEvent.getAggregateId(), partialDeselectEvent);

		kafkaTemplate.send(settings_topic, partialDeselectEvent.getAggregateId(), partialDeselectEvent);





		Event select = (Event) blockingQueue.poll(120, TimeUnit.SECONDS);

		Event select = (Event) blockingQueue.poll(120, TimeUnit.SECONDS);
@@ -697,7 +695,7 @@ public class SettingsCommandHandlerBase extends KafkaBaseIntegrationTest { 




		// Añade completableFeature para que se resuelva al recibir el mensaje.

		// Añade completableFeature para que se resuelva al recibir el mensaje.

		CompletableFuture<SettingsDTO> completableFuture = Whitebox.invokeMethod(settingsCommandHandler,

		CompletableFuture<SettingsDTO> completableFuture = Whitebox.invokeMethod(settingsCommandHandler,

				"getCompletableFeature", event.getSessionId(), settingsSavedEvent.getSettings());

				"getCompletableFeature", event.getSessionId());





		kafkaTemplate.send(settings_topic, event.getAggregateId(), event);

		kafkaTemplate.send(settings_topic, event.getAggregateId(), event);