Commit 43fe88fe authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia tests para simular situación real de error

parent 08a5b455

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

+21 −4
Original line number Diff line number Diff line
@@ -66,6 +66,7 @@ import es.redmic.vesselslib.events.vessel.update.UpdateVesselEvent; 
import es.redmic.vesselslib.events.vessel.update.UpdateVesselFailedEvent;

import es.redmic.vesselslib.events.vessel.update.VesselUpdatedEvent;

import es.redmic.vesselslib.events.vesseltracking.create.VesselTrackingCreatedEvent;

import es.redmic.vesselslib.events.vesseltype.create.CreateVesselTypeConfirmedEvent;

import es.redmic.vesselslib.events.vesseltype.create.VesselTypeCreatedEvent;



@RunWith(SpringJUnit4ClassRunner.class)
@@ -125,11 +126,19 @@ public class VesselCommandHandlerTest extends KafkaBaseIntegrationTest { 


		String code = "1234";



		// Envía Create vesseltype para simular otros eventos anteriores

		CreateVesselTypeConfirmedEvent createVesselTypeConfirmedEvent = VesselTypeDataUtil

				.getCreateVesselTypeConfirmedEvent(code);

		kafkaTemplate.send(vessel_type_topic, createVesselTypeConfirmedEvent.getAggregateId(),

				createVesselTypeConfirmedEvent);



		// Envía vesseltypeCreated

		VesselTypeCreatedEvent vesselTypeCreatedEvent = VesselTypeDataUtil.getVesselTypeCreatedEvent(code);

		VesselTypeCreatedEvent vesselTypeCreatedEvent = new VesselTypeCreatedEvent()

				.buildFrom(createVesselTypeConfirmedEvent);

		vesselTypeCreatedEvent.setVesselType(VesselTypeDataUtil.getVesselType(code));

		kafkaTemplate.send(vessel_type_topic, vesselTypeCreatedEvent.getAggregateId(), vesselTypeCreatedEvent);



		Thread.sleep(2000);

		Thread.sleep(4000);



		// Envía enrichCreateVessel con id del vesseltype igual al enviado
@@ -182,11 +191,19 @@ public class VesselCommandHandlerTest extends KafkaBaseIntegrationTest { 
		// Envía vesseltypeCreated

		String code = "1235";



		// Envía Create vesseltype para simular otros eventos anteriores

		CreateVesselTypeConfirmedEvent createVesselTypeConfirmedEvent = VesselTypeDataUtil

				.getCreateVesselTypeConfirmedEvent(code);

		kafkaTemplate.send(vessel_type_topic, createVesselTypeConfirmedEvent.getAggregateId(),

				createVesselTypeConfirmedEvent);



		// Envía vesseltypeCreated

		VesselTypeCreatedEvent vesselTypeCreatedEvent = VesselTypeDataUtil.getVesselTypeCreatedEvent(code);

		VesselTypeCreatedEvent vesselTypeCreatedEvent = new VesselTypeCreatedEvent()

				.buildFrom(createVesselTypeConfirmedEvent);

		vesselTypeCreatedEvent.setVesselType(VesselTypeDataUtil.getVesselType(code));

		kafkaTemplate.send(vessel_type_topic, vesselTypeCreatedEvent.getAggregateId(), vesselTypeCreatedEvent);



		Thread.sleep(2000);

		Thread.sleep(4000);



		// Envía enrichUpdateVessel con id del vesseltype igual al enviado

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

+17 −8
Original line number Diff line number Diff line
@@ -43,6 +43,7 @@ import es.redmic.vesselscommands.VesselsCommandsApplication; 
import es.redmic.vesselscommands.handler.VesselTrackingCommandHandler;

import es.redmic.vesselslib.dto.tracking.VesselTrackingDTO;

import es.redmic.vesselslib.dto.vessel.VesselDTO;

import es.redmic.vesselslib.events.vessel.create.CreateVesselConfirmedEvent;

import es.redmic.vesselslib.events.vessel.create.VesselCreatedEvent;

import es.redmic.vesselslib.events.vesseltracking.VesselTrackingEventTypes;

import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingCancelledEvent;
@@ -115,12 +116,15 @@ public class VesselTrackingCommandHandlerTest extends KafkaBaseIntegrationTest { 


		String tstamp = String.valueOf(new DateTime().getMillis());



		// Envía Create vessel para simular otros eventos anteriores

		CreateVesselConfirmedEvent createVesselConfirmedEvent = VesselDataUtil.getCreateVesselConfirmedEvent(mmsi);

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



		// Envía vesselCreated

		VesselCreatedEvent vesselCreatedEvent = VesselDataUtil.getVesselCreatedEvent(mmsi);

		VesselCreatedEvent vesselCreatedEvent = new VesselCreatedEvent().buildFrom(createVesselConfirmedEvent);

		vesselCreatedEvent.setVessel(VesselDataUtil.getVessel(mmsi));

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



		Thread.sleep(2000);



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



		EnrichCreateVesselTrackingEvent enrichCreateVesselTrackingEvent = VesselTrackingDataUtil
@@ -142,8 +146,10 @@ public class VesselTrackingCommandHandlerTest extends KafkaBaseIntegrationTest { 
		assertNotNull(confirm);

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



		assertEquals(vesselCreatedEvent.getVessel(),

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

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

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

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

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

	}



	// Envía un evento de confirmación de creación y debe provocar un evento Created
@@ -187,12 +193,15 @@ public class VesselTrackingCommandHandlerTest extends KafkaBaseIntegrationTest { 


		String tstamp = String.valueOf(new DateTime().getMillis());



		// Envía Create vessel para simular otros eventos anteriores

		CreateVesselConfirmedEvent createVesselConfirmedEvent = VesselDataUtil.getCreateVesselConfirmedEvent(mmsi);

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



		// Envía vesselCreated

		VesselCreatedEvent vesselCreatedEvent = VesselDataUtil.getVesselCreatedEvent(mmsi);

		VesselCreatedEvent vesselCreatedEvent = new VesselCreatedEvent().buildFrom(createVesselConfirmedEvent);

		vesselCreatedEvent.setVessel(VesselDataUtil.getVessel(mmsi));

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



		Thread.sleep(2000);



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



		EnrichUpdateVesselTrackingEvent enrichUpdateVesselTrackingEvent = VesselTrackingDataUtil