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

Añade enriquecimiento de vesselTracking 

De esta manera, se almacena el vessel enriquecido dentro de track
parent d5472f5b

vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselTrackingEventStreams.java

+2 −2
Original line number Diff line number Diff line
@@ -18,7 +18,7 @@ import es.redmic.vesselslib.events.vesseltracking.VesselTrackingEventFactory; 
import es.redmic.vesselslib.events.vesseltracking.VesselTrackingEventTypes;

import es.redmic.vesselslib.events.vesseltracking.common.VesselTrackingEvent;

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

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

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

import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingEnrichedEvent;



public class VesselTrackingEventStreams extends EventSourcingStreams {
@@ -277,7 +277,7 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 


			vesselTrackingDTO = new CreateVesselTrackingCommand(vesselTrackingDTO).getVesselTracking();



			CreateVesselTrackingEvent evt = new CreateVesselTrackingEvent(vesselTrackingDTO);

			EnrichCreateVesselTrackingEvent evt = new EnrichCreateVesselTrackingEvent(vesselTrackingDTO);

			evt.setAggregateId(vesselTrackingDTO.getId());

			evt.setVersion(1);

			evt.setUserId(REDMIC_PROCESS);

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

+3 −3
Original line number Diff line number Diff line
@@ -33,7 +33,7 @@ import es.redmic.testutils.kafka.KafkaBaseIntegrationTest; 
import es.redmic.vesselscommands.VesselsCommandsApplication;

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

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

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

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



@RunWith(SpringJUnit4ClassRunner.class)

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



	@KafkaHandler

	public void listen(CreateVesselTrackingEvent createVesselTrackingEvent) throws Exception {

	public void listen(EnrichCreateVesselTrackingEvent enrichCreateVesselTrackingEvent) throws Exception {



		blockingQueue.offer(createVesselTrackingEvent.getVesselTracking());

		blockingQueue.offer(enrichCreateVesselTrackingEvent.getVesselTracking());

	}



	@KafkaHandler(isDefault = true)