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

Añade un timeout mayor para procesos automatizados

parent 599c18ea

vessels-commands/src/main/java/es/redmic/vesselscommands/commands/VesselCommandHandler.java

+9 −0
Original line number Diff line number Diff line
@@ -59,6 +59,11 @@ public class VesselCommandHandler extends CommandHandler { 
	@Value("${stream.windows.time.ms}")

	private Long streamWindowsTime;



	@Value("${process.eventsource.timeout.ms}")

	private long processTimeoutMS;



	private final String REDMIC_PROCESS = "REDMIC_PROCESS";



	private VesselStateStore vesselStateStore;



	@Autowired
@@ -130,6 +135,10 @@ public class VesselCommandHandler extends CommandHandler { 
		// Emite evento para enviar a kafka

		publishToKafka(event, vessel_topic);



		// Se resuelve con un timeout mayor, establecido para procesos automáticos

		if (event.getUserId().equals(REDMIC_PROCESS))

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



		// Obtiene el resultado cuando se resuelva la espera

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

	}

vessels-commands/src/main/resources/application.properties

+3 −2
Original line number Diff line number Diff line
@@ -37,8 +37,9 @@ spring.kafka.consumer.value-deserializer=io.confluent.kafka.serializers.KafkaAvr 
#spring.kafka.properties.consumer.request.timeout.ms=

#spring.kafka.properties.producer.request.timeout.ms=



eventsource.timeout.ms=120000

stream.windows.time.ms=120000

rest.eventsource.timeout.ms=300000

process.eventsource.timeout.ms=2400000

stream.windows.time.ms=2400000



spring.kafka.properties.specific.avro.reader=true

spring.kafka.properties.value.subject.name.strategy=io.confluent.kafka.serializers.subject.TopicRecordNameStrategy