Commit 6e86a849 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade función: envía evento y espera por resultado

parent 68655b83
Loading
Loading
Loading
Loading
+12 −0
Original line number Diff line number Diff line
@@ -132,4 +132,16 @@ public abstract class CommandHandler implements ApplicationEventPublisherAware {
			completableFeatures.remove(sessionId);
		}
	}

	protected <T> T sendEventAndWaitResult(Event event, String topic) {

		// Crea la espera hasta que se responda con evento completado
		CompletableFuture<T> completableFuture = getCompletableFeature(event.getSessionId());

		// Emite evento para enviar a kafka
		publishToKafka(event, topic);

		// Obtiene el resultado cuando se resuelva la espera
		return getResult(event.getSessionId(), completableFuture);
	}
}