Commit 092956d3 authored by Noel Alonso's avatar Noel Alonso
Browse files

Amplía test comprobando que hace enriquecimiento

parent b3793ef9

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

+3 −3
Original line number Diff line number Diff line
@@ -34,7 +34,7 @@ import es.redmic.test.vesselscommands.integration.KafkaEmbeddedConfig; 
import es.redmic.testutils.kafka.KafkaBaseIntegrationTest;

import es.redmic.vesselscommands.VesselsCommandsApplication;

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

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

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



@RunWith(SpringJUnit4ClassRunner.class)

@TestPropertySource(properties = { "spring.kafka.consumer.group-id=CreateVesselFromAIS", "schema.registry.port=18082" })
@@ -100,9 +100,9 @@ public class CreateVesselFromAISTest extends KafkaBaseIntegrationTest { 
	}



	@KafkaHandler

	public void listen(EnrichCreateVesselEvent createEvent) {

	public void listen(CreateVesselEnrichedEvent createVesselEnrichedEvent) {



		blockingQueue.offer(createEvent.getVessel());

		blockingQueue.offer(createVesselEnrichedEvent.getVessel());

	}



	@KafkaHandler(isDefault = true)

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

+5 −4
Original line number Diff line number Diff line
@@ -42,7 +42,7 @@ import es.redmic.vesselscommands.service.VesselTrackingCommandService; 
import es.redmic.vesselslib.dto.tracking.VesselTrackingDTO;

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

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

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

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



@RunWith(SpringJUnit4ClassRunner.class)

@TestPropertySource(properties = { "spring.kafka.consumer.group-id=CreateVesselTrackingFromAIS",
@@ -147,12 +147,13 @@ public class CreateVesselTrackingFromAISTest extends KafkaBaseIntegrationTest { 
	}



	@KafkaHandler

	public void listen(EnrichCreateVesselTrackingEvent createEvent) throws Exception {

	public void listen(CreateVesselTrackingEnrichedEvent createVesselTrackingEnrichedEvent) throws Exception {



		// Resuelve la espera para que siga la ejecución

		Whitebox.invokeMethod(vesselTrackingCommandHandler, "resolveCommand", createEvent.getSessionId());

		Whitebox.invokeMethod(vesselTrackingCommandHandler, "resolveCommand",

				createVesselTrackingEnrichedEvent.getSessionId());



		blockingQueue.offer(createEvent.getVesselTracking());

		blockingQueue.offer(createVesselTrackingEnrichedEvent.getVesselTracking());

	}



	@KafkaHandler(isDefault = true)