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

Arregla tests, aumentando el tiempo 

Además se debe garantizar la sesión
parent 5b4ea76e

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

+1 −1
Original line number Diff line number Diff line
@@ -89,7 +89,7 @@ public class CreateVesselFromTrackingTest extends KafkaBaseIntegrationTest { 
				.send(REALTIME_TRACKING_VESSELS_TOPIC, "vessel-mmsi-" + dto.getMmsi(), dto);

		future.addCallback(new SendListener());



		VesselDTO vessel = (VesselDTO) blockingQueue.poll(30, TimeUnit.SECONDS);

		VesselDTO vessel = (VesselDTO) blockingQueue.poll(60, TimeUnit.SECONDS);

		assertNotNull(vessel);

		assertEquals(vessel.getMmsi(), dto.getMmsi());

		assertEquals(vessel.getName(), dto.getName());

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

+4 −2
Original line number Diff line number Diff line
@@ -48,7 +48,7 @@ import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingEve 
@SpringBootTest(classes = { VesselsCommandsApplication.class })

@ActiveProfiles("test")

@DirtiesContext

@KafkaListener(topics = "${broker.topic.vessel-tracking}", groupId = "test")

@KafkaListener(topics = "${broker.topic.vessel-tracking}", groupId = "testCreateVesselTrackingFromAISTest")

public class CreateVesselTrackingFromAISTest extends KafkaBaseIntegrationTest {



	@Value("${broker.topic.realtime.tracking.vessels}")
@@ -113,7 +113,7 @@ public class CreateVesselTrackingFromAISTest extends KafkaBaseIntegrationTest { 
				.send(REALTIME_TRACKING_VESSELS_TOPIC, dto.getMmsi().toString(), dto);

		future.addCallback(new SendListener());



		VesselTrackingDTO vesselTracking = (VesselTrackingDTO) blockingQueue.poll(120, TimeUnit.SECONDS);

		VesselTrackingDTO vesselTracking = (VesselTrackingDTO) blockingQueue.poll(60, TimeUnit.SECONDS);

		assertNotNull(vesselTracking);



		assertTrue(vesselTracking.getProperties().getDate().isEqual(dto.getTstamp()));
@@ -138,6 +138,8 @@ public class CreateVesselTrackingFromAISTest extends KafkaBaseIntegrationTest { 
	@KafkaListener(topics = "${broker.topic.vessel}", groupId = "test")

	public void listen(Event event) {



		vesselCreatedEvent.setSessionId(event.getSessionId());



		if (event.getType().equals(VesselEventTypes.CREATE)) {

			ListenableFuture<SendResult<String, Event>> futureCreatedEvent = kafkaTemplateEvent.send(VESSEL_TOPIC,

					"vessel-mmsi-" + mmsi, vesselCreatedEvent);