Commit 3639650c authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade espera para que los eventos llegen al topic

parent 4b981be8

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

+4 −0
Original line number Diff line number Diff line
@@ -335,6 +335,8 @@ public class VesselCommandHandlerTest extends KafkaBaseIntegrationTest { 
		Event updated = (Event) blockingQueue.poll(20, TimeUnit.SECONDS);

		assertNotNull(updated);



		Thread.sleep(8000);



		// Envía failed y espera un evento de cancelled con el vessel original dentro

		UpdateVesselFailedEvent event = VesselDataUtil.getUpdateVesselFailedEvent(mmsi + 5);
@@ -406,6 +408,8 @@ public class VesselCommandHandlerTest extends KafkaBaseIntegrationTest { 
		kafkaTemplate.send(vessel_topic, vesselUpdateEvent.getAggregateId(), vesselUpdateEvent);

		blockingQueue.poll(10, TimeUnit.SECONDS);



		Thread.sleep(8000);



		// Envía failed y espera un evento de cancelled con el vessel original dentro

		DeleteVesselFailedEvent event = VesselDataUtil.getDeleteVesselFailedEvent(mmsi + 6);

vessels-commands/src/test/java/es/redmic/test/vesselscommands/integration/vesseltracking/VesselTrackingCommandHandlerTest.java

+12 −2
Original line number Diff line number Diff line
@@ -125,6 +125,8 @@ public class VesselTrackingCommandHandlerTest extends KafkaBaseIntegrationTest { 
		vesselCreatedEvent.setVessel(VesselDataUtil.getVessel(mmsi));

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



		Thread.sleep(4000);



		// Envía enrichCreateVesselTracking con id del vessel igual al enviado



		EnrichCreateVesselTrackingEvent enrichCreateVesselTrackingEvent = VesselTrackingDataUtil
@@ -202,6 +204,8 @@ public class VesselTrackingCommandHandlerTest extends KafkaBaseIntegrationTest { 
		vesselCreatedEvent.setVessel(VesselDataUtil.getVessel(mmsi));

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



		Thread.sleep(4000);



		// Envía enrichUpdateVesselTracking con id del vessel igual al enviado



		EnrichUpdateVesselTrackingEvent enrichUpdateVesselTrackingEvent = VesselTrackingDataUtil
@@ -223,8 +227,10 @@ public class VesselTrackingCommandHandlerTest extends KafkaBaseIntegrationTest { 
		assertNotNull(confirm);

		assertEquals(VesselTrackingEventTypes.UPDATE, confirm.getType());



		assertEquals(vesselCreatedEvent.getVessel(),

				((UpdateVesselTrackingEvent) confirm).getVesselTracking().getProperties().getVessel());

		assertEquals(vesselCreatedEvent.getVessel().getName(),

				((UpdateVesselTrackingEvent) confirm).getVesselTracking().getProperties().getVessel().getName());

		assertEquals(vesselCreatedEvent.getVessel().getType(),

				((UpdateVesselTrackingEvent) confirm).getVesselTracking().getProperties().getVessel().getType());

	}



	// Envía un evento de confirmación de modificación y debe provocar un evento
@@ -343,6 +349,8 @@ public class VesselTrackingCommandHandlerTest extends KafkaBaseIntegrationTest { 
		Event updated = (Event) blockingQueue.poll(20, TimeUnit.SECONDS);

		assertNotNull(updated);



		Thread.sleep(8000);



		// Envía failed y espera un evento de cancelled con el vesselTracking original

		// dentro

		UpdateVesselTrackingFailedEvent event = VesselTrackingDataUtil.getUpdateVesselTrackingFailedEvent(mmsi + 5,
@@ -390,6 +398,8 @@ public class VesselTrackingCommandHandlerTest extends KafkaBaseIntegrationTest { 
				vesselTrackingUpdateEvent);

		blockingQueue.poll(10, TimeUnit.SECONDS);



		Thread.sleep(8000);



		// Envía failed y espera un evento de cancelled con el vesselTracking original

		// dentro

		DeleteVesselTrackingFailedEvent event = VesselTrackingDataUtil.getDeleteVesselTrackingFailedEvent(mmsi + 6,

vessels-commands/src/test/java/es/redmic/test/vesselscommands/integration/vesseltype/VesselTypeCommandHandlerTest.java

+4 −0
Original line number Diff line number Diff line
@@ -244,6 +244,8 @@ public class VesselTypeCommandHandlerTest extends KafkaBaseIntegrationTest { 
		kafkaTemplate.send(vessel_type_topic, vesselTypeUpdateEvent.getAggregateId(), vesselTypeUpdateEvent);

		blockingQueue.poll(20, TimeUnit.SECONDS);



		Thread.sleep(8000);



		// Envía failed y espera un evento de cancelled con el vessel original dentro

		UpdateVesselTypeFailedEvent event = VesselTypeDataUtil.getUpdateVesselTypeFailedEvent(code + "5");
@@ -311,6 +313,8 @@ public class VesselTypeCommandHandlerTest extends KafkaBaseIntegrationTest { 
		kafkaTemplate.send(vessel_type_topic, vesselTypeUpdateEvent.getAggregateId(), vesselTypeUpdateEvent);

		blockingQueue.poll(10, TimeUnit.SECONDS);



		Thread.sleep(8000);



		// Envía failed y espera un evento de cancelled con el vessel original dentro

		DeleteVesselTypeFailedEvent event = VesselTypeDataUtil.getDeleteVesselTypeFailedEvent(code + "6");