Commit 9772685d authored by Noel Alonso's avatar Noel Alonso
Browse files

Aumenta tiempo de espera entre mensajes para test

parent 3c7a4f2b

vessels-commands/src/test/java/es/redmic/test/vesselscommands/integration/vessel/VesselPostUpdateHandlerTest.java

+4 −4
Original line number Diff line number Diff line
@@ -110,23 +110,23 @@ public class VesselPostUpdateHandlerTest extends KafkaBaseIntegrationTest { 
		// Envía created para que genere un evento postUpdate y lo saca de la cola

		VesselCreatedEvent vesselCreatedEvent = VesselDataUtil.getVesselCreatedEvent(mmsi + 7);

		kafkaTemplate.send(VESSEL_TOPIC, vesselCreatedEvent.getAggregateId(), vesselCreatedEvent);

		Thread.sleep(2000);

		Thread.sleep(3000);



		// Envía created para que genere un evento postUpdate y lo saca de la cola

		VesselCreatedEvent vesselCreatedEvent2 = VesselDataUtil.getVesselCreatedEvent(mmsi + 8);

		kafkaTemplate.send(VESSEL_TOPIC, vesselCreatedEvent2.getAggregateId(), vesselCreatedEvent2);

		Thread.sleep(2000);

		Thread.sleep(3000);



		// Envía created con vesselType actualizado para comprobar que no genera evento

		VesselCreatedEvent vesselCreatedEvent3 = VesselDataUtil.getVesselCreatedEvent(mmsi + 9);

		vesselCreatedEvent3.getVessel().setType(vesselTypeUpdatedEvent.getVesselType());

		kafkaTemplate.send(VESSEL_TOPIC, vesselCreatedEvent3.getAggregateId(), vesselCreatedEvent3);

		Thread.sleep(2000);

		Thread.sleep(3000);



		// Envía create para simular uno a medias en el stream y lo saca de la cola

		CreateVesselEvent createVesselEvent = VesselDataUtil.getCreateEvent(mmsi + 10);

		kafkaTemplate.send(VESSEL_TOPIC, createVesselEvent.getAggregateId(), createVesselEvent);

		Thread.sleep(2000);

		Thread.sleep(3000);



		// Envía evento de vesselType actualizado para que genere los eventos de

		// postUpdate